程序中幾個(gè)線程一起往控制臺(tái)寫入log_info，但是可以很清楚的看到begin or write_process不會(huì)同時(shí)連續(xù)的出現(xiàn)，而且在begin of write_process和end of write_process之間肯定不會(huì)出現(xiàn)begin of read_process或者end of read_process。但是begin of read_process卻會(huì)在控制臺(tái)上連續(xù)出現(xiàn)，這說(shuō)明在同一時(shí)刻只有一個(gè)write_prcess在運(yùn)行，但是wrte_process沒(méi)有運(yùn)行的時(shí)候，會(huì)有多個(gè)read_process并發(fā)運(yùn)行。
1 #include <iostream>
2
3 #include <boost/thread/thread.hpp>
4 #include <boost/thread/shared_mutex.hpp>
5
6 using namespace std;
7 using namespace boost;
8
9 boost::shared_mutex shr_mutex;
10
11 /// 這個(gè)是輔助類，能夠保證log_info被完整的輸出
12 class safe_log {
13 public:
14 static void log(const std::string& log_info) {
15 boost::mutex::scoped_lock lock(log_mutex);
16 cout << log_info << endl;
17 }
18
19 private:
20 static boost::mutex log_mutex;
21 };
22
23 boost::mutex safe_log::log_mutex;
24
25 void write_process() {
26 shr_mutex.lock();
27 safe_log::log("begin of write_process");
28 safe_log::log("end of write_process");
29 shr_mutex.unlock();
30 }
31
32 void read_process() {
33 shr_mutex.lock_shared();
34 safe_log::log("begin of read_process");
35 safe_log::log("end of read_process");
36 shr_mutex.unlock_shared();
37 }
38
39 int main() {
40
41 thread_group threads;
42 for (int i = 0; i < 10; ++ i) {
43 threads.create_thread(&write_process);
44 threads.create_thread(&read_process);
45 }
46
47 threads.join_all();
48
49 ::system("PAUSE");
50
51 return 0;
52 }
posted on 2009-01-21 13:58
許海斌 閱讀(2660)
評(píng)論(0) 編輯 收藏 引用