谁来来帮我看看这个简单的线程池(c++11)

gaojl0728

回复 10# lost_templar

simple_thread_pool在析构的时候会先析构joiner, 然后才是自己， 也就是all_done_flag = true， 想明白了没
~simple_thread_pool()
{
    all_done_flag = true;
}

lost_templar

gaojl0728 发表于 2014-04-30 15:48
回复 10# lost_templar

simple_thread_pool在析构的时候会先析构joiner, 然后才是自己， 也就是all_don ...

测试显示不是这样的

1. cat m.cc && g++-4.9 -o m m.cc && ./m
   
2. #include <iostream>
   
3. 
   
4. struct s
   
5. {
   
6.     ~s()
   
7.     {
   
8.         std::cout << "~s\n";
   
9.     }
   
10. };
    
11. 
    
12. struct t
    
13. {
    
14.     s s_;
    
15.     ~t()
    
16.     {
    
17.         std::cout << "~t\n";
    
18.     }
    
19. };
    
20. 
    
21. int main()
    
22. {
    
23.     t t_;
    
24.     return 0;
    
25. }
    
26. ~t
    
27. ~s

复制代码

gaojl0728

回复 12# lost_templar

对， 是我想错了， 析构是反顺序的， 我想错了。

gaojl0728

整体上写的挺好！

gaojl0728

回复 12# lost_templar


那这样为什么还会有你说的那个问题？你打印下确定the_thread.joinable()返回的是true吗？
if ( the_thread.joinable() )
    the_thread.join();

windoze

回复 8# gaojl0728

Yield的那个忙循环时是拿了锁的啊，新任务怎么放得进去？

gaojl0728

回复 16# windoze


    外面有个大括号啊， 执行完了会释放锁

lost_templar

回复 16# windoze


    我这样修改了也不成的：

1.         void work_loader()
   
2.         {
   
3.             while ( ! all_done_flag )
   
4.             {
   
5.             /*
   
6.                 function_type current_work;
   
7.                 {
   
8.                     std::lock_guard<std::mutex> lg{ work_queue_mutex };
   
9.                     if ( work_queue.empty() )
   
10.                     {
    
11.                         current_work = [](){ std::this_thread::yield(); };
    
12.                     }
    
13.                     else
    
14.                     {
    
15.                         current_work = work_queue.front();
    
16.                         work_queue.pop();
    
17.                         ++job_executed;
    
18.                     }
    
19.                 }
    
20.                 current_work();
    
21.             */
    
22. 
    
23.                 function_type current_work = nullptr;
    
24. 
    
25.                 {
    
26.                     std::lock_guard<std::mutex> lg{ work_queue_mutex };
    
27.                     if ( !work_queue.empty() )
    
28.                     {
    
29.                         current_work = work_queue.front();
    
30.                         work_queue.pop();
    
31.                         ++job_executed;
    
32.                     }
    
33.                 }
    
34. 
    
35.                 if ( !current_work )
    
36.                     current_work = [](){ std::this_thread::yield(); };
    
37. 
    
38.                 current_work();
    
39.             }
    
40.         }
    

复制代码

lost_templar

回复 15# gaojl0728


    这个地方木有问题，我确认过

    等等我把全部代码贴一下，不过非常长～～

lost_templar

回复 19# lost_templar


    将近6万行，还是算了