boost_thread库求教

tweyseo

小弟最近在研究boost thread库
下面是自己写的1个基本的多线程处理事务的模型 跑是基本没问题 但是不懂效率上来讲 合理么
先谢谢各位了

1. #include <iostream>
   
2. #include <boost/thread.hpp>
   
3. #include <boost/bind.hpp>
   
4. #include <list>
   
5. 
   
6. using namespace std;
   
7. 
   
8. boost::mutex mutex;
   
9. 
   
10. class ThreadMgr
    
11. {
    
12. public:
    
13. 
    
14.     ThreadMgr(int i)
    
15.         : m_work_flag(true),m_thread_num(i)
    
16.     {
    
17.         m_works.clear();
    
18.         Start();
    
19.     }
    
20. 
    
21.     ~ThreadMgr()
    
22.     {
    
23.         m_thread_list.join_all();
    
24.     }
    
25. 
    
26.     void Stop()
    
27.     {
    
28.         m_work_flag = false;
    
29.     }
    
30. 
    
31.     void AddWork(int i)
    
32.     {
    
33.         m_works.push_back(i);
    
34.     }
    
35. 
    
36. private:
    
37. 
    
38.     void Start()
    
39.     {
    
40.         for (int i = 0; i < m_thread_num; ++i)
    
41.         {
    
42.             boost::thread* work = new boost::thread(boost::bind(&ThreadMgr::CallThread, this));
    
43.             m_thread_list.add_thread(work);
    
44.         }
    
45.     }
    
46. 
    
47.     void CallThread()
    
48.     {
    
49.         while (m_work_flag)
    
50.         {
    
51.             int i = 0;
    
52.             // 这里对m_work_flag的判断是为了在关闭按钮触发后及时停止后台的线程
    
53.             while(m_work_flag && GetWork(i))
    
54.             {
    
55.                 boost::unique_lock<boost::mutex> lock(mutex);
    
56.                 cout << "thread[" << boost::this_thread::get_id() << "] is doing work[" << i << "]." << endl;
    
57.             }
    
58.         }
    
59. 
    
60.     }
    
61. 
    
62.     bool GetWork(int& i)
    
63.     {
    
64.         boost::unique_lock<boost::mutex> lock(mutex);
    
65.         if (m_works.empty())
    
66.         {
    
67.             return false;
    
68.         }
    
69. 
    
70.         i = m_works.front();
    
71.         m_works.pop_front();
    
72.         return true;
    
73.     }
    
74. 
    
75.     boost::thread_group    m_thread_list;
    
76.     list<int> m_works;
    
77.     bool m_work_flag;
    
78.     int m_thread_num;
    
79. };
    
80. 
    
81. int main()
    
82. {
    
83.     ThreadMgr* tm = new ThreadMgr(4);
    
84. 
    
85.     for (int i = 1; i < 10; ++i)
    
86.     {
    
87.         tm->AddWork(i);
    
88.     }
    
89. 
    
90.     for (int i = 10; i < 20; ++i)
    
91.     {
    
92.         tm->AddWork(i);
    
93.     }
    
94. 
    
95.     tm->Stop();    // 关闭按钮之类的触发
    
96. 
    
97.     delete tm;
    
98. 
    
99.     return 0;
    
100. }

复制代码

tweyseo

各位大侠帮看看呀

fallening

要讲求效率的话，可以考虑动态设定线程数量；大致来说，我认为，在有 n 个 cpu 的情形下，可以考虑开 n-1 个线程处理数据，同时主程序也处理一部分，最后合并。

samzc2010

接话题咨询一下：
boost thread库比较POSIX pthread有啥区别和优势？

tweyseo

回复 4# samzc2010


    个人觉得是移植性 还有易用性 很恰到好处的利用了boost的bind和function

tweyseo

发现在57和58之间要加入1句
boost::this_thread::sleep(boost::posix_time::milliseconds(1));

在任务列表为空的时候交出cpu

tweyseo

发现在57和58之间要加入1句
boost::this_thread::sleep(boost::posix_time::milliseconds(1));

在任务列表为空的时候交出cpu