软件下载 | 资讯教程 | 最近更新 | 下载排行 | 一键转帖 | 发布投稿
您的位置:最火下载站 > 电脑教程 > 编程开发 > C/C++开发 > C++库BOOST中如何实现线程安全代码

C++库BOOST中如何实现线程安全代码

C++库BOOST中如何实现线程安全代码

1 需要include <boost/thread.hpp>
2 背景知识请参考《boost程序库完全开发指南》第12章
3 编绎:g++ -o mthread mthread.cpp -lboost_thread -L/usr/local/lib

Copy to ClipboardLiehuo.Net Codes引用的内容:[www.veryhuo.com]
#include <boost/thread.hpp>
using namespace boost;
using namespace std;

mutex io_mu; // 定认全局互斥变量

/*
* 模板类: 线程安全的计数器,不可拷贝
*/
template<typename T>
class basic_atom: noncopyable
{
private:
T n;
mutex mu;
public:
basic_atom(T x = T()) :n(x) {}
T operator++() {
mutex::scoped_lock lock(mu); //用scoped_lock锁住成员互斥信号变量
return ++n;
}
operator T() { return n; }
};

typedef basic_atom<int> atom_int; // 将模板类定义精简名atom_int

int to_interrupt(atom_int& x, const string& str)
try {
for (int i = 0; i < 9; ++i) {
this_thread::sleep(posix_time::seconds(1)); // 此处应该是子线程sleep1秒
mutex::scoped_lock lock(io_mu); //io流非线程安全,必须锁住
cout << str << ": " << ++x << endl;
}
} catch(thread_interrupted& ) {
cout << "thread interrupted" << endl;
}

int main()
{
atom_int x;
thread t(to_interrupt, ref(x), "hello"); // t调用to_interrupt函数,并输出hello x
this_thread::sleep(posix_time::seconds(3)); //此处应该是主线程睡眠3秒
t.interrupt(); // 调用线程的中断操作
t.join(); // 因为线程已中断,所以线程立即返回
}
    相关阅读
    栏目导航
    推荐软件