1 需要include <boost/thread.hpp>
2 背景知识请参考《boost程序库完全开发指南》第12章
3 编绎：g++ -o mthread mthread.cpp -lboost_thread -L/usr/local/lib
2 背景知识请参考《boost程序库完全开发指南》第12章
3 编绎：g++ -o mthread mthread.cpp -lboost_thread -L/usr/local/lib
标签： Boost
代码片段(1)[全屏查看所有代码]
1. [代码][C/C++]代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
#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(); // 因为线程已中断，所以线程立即返回
} |