多线程退出的该如何维护？

naiza

我专门建立了一个维护线程用来做其它工作线程退出后的清理。这个维护线程的run就是等待一个全局的条件变量，收到信号就处理然后继续等待用while(1)；每个工作线程退出前触发这个全局条件变量。
我现在发现有个问题是，有多个线程同时退出话他们发的信号不能被全部处理总有丢失的，发信号我用全局的锁不能控制吗还是这样做有问题呢？各位老大帮忙分析下，代码有点乱 不知这样说能否明白我的意思

忘说了，是linux下的posix线程，第一次用

surfzsl

你先看看线程条件变量、线程的信号处理吧
你的程序设计的估计有问题
另外，很少用忙等作为等待条件的

naiza

原帖由 "surfzsl" 发表：
你先看看线程条件变量、线程的信号处理吧
你的程序设计的估计有问题
另外，很少用忙等作为等待条件的

我现在也怀疑我这样设计有问题 根据我的理解写出的代码，不知我的用法是否正确呢？

1. 
   
2. //进行线程退出处理的线程
   
3. void CMaintainThread::run()
   
4. {
   
5.          while(1)
   
6.         {
   
7.                 g_pCondition->;Wait(); //g_pCondition是我的全局变量
   
8.                                    //是条件变量封装类CMyCondition实例
   
9.      }
   
10.         pthread_exit(NULL);
    
11. }
    
12. 
    
13. //工作线程
    
14. void CWorkerThread::run()
    
15. {
    
16.       ......
    
17.        pthread_mutex_lock(&(g_pCondition->;m_Mutex));
    
18.        g_pCondition->;Wake(this);
    
19.        pthread_mutex_unlock(&(g_pCondition->;m_Mutex));
    
20.        pthread_exit(NULL);
    
21. }
    
22. 
    
23. //条件变量封装类
    
24. class CMyCondition
    
25. {
    
26. pubic:
    
27.         pthread_mutex_t  m_Mutex;
    
28.         pthread_cond_t m_Cond;
    
29.         CWorkerThread *m_pt;
    
30. public:
    
31.         int Wait(int second=0);
    
32.         int Wake(CWorkerThread *pt);
    
33.         ......
    
34. }
    
35. 
    
36. int CMyCondition::Wait(int second)
    
37. {
    
38.         struct timeval now;
    
39.         struct timespec timeout;
    
40.         int iRetCode;
    
41. 
    
42.         iRetCode = pthread_mutex_lock(&m_Mutex);
    
43.         if (iRetCode)
    
44.         {
    
45.                 perror("pthread_mutex_lock\n");
    
46.                 pthread_exit(NULL);
    
47.         }
    
48. 
    
49.         m_pt = NULL;
    
50.         if (second)
    
51.         {
    
52.                 gettimeofday(&now, NULL);
    
53.                 timeout.tv_sec = now.tv_sec + second;
    
54.                 timeout.tv_nsec = now.tv_usec * 1000;
    
55. 
    
56.                 m_iError = pthread_cond_timedwait(&m_Cond, &m_Mutex, &timeout);
    
57.         }
    
58.         else
    
59.                 m_iError = pthread_cond_wait(&m_Cond, &m_Mutex);
    
60. 
    
61.         switch(m_iError)
    
62.         {
    
63.                 case 0:
    
64.                         //根据线程指针m_pt执行线程清理操作......
    
65.                         pthread_mutex_unlock(&m_Mutex);
    
66.                         return 0;
    
67.                 case ETIMEDOUT:
    
68.                         pthread_mutex_unlock(&m_Mutex);
    
69.                         return 1;
    
70.                 default:
    
71.                         pthread_mutex_unlock(&m_Mutex);
    
72.                         return 2;
    
73.         }
    
74. }
    
75. 
    
76. int CMyCondition::Wake(CWorkerThread  *pt)
    
77. {
    
78.         m_pt = pt;
    
79.         pthread_cond_signal(&m_Cond);
    
80. }
    

复制代码

菜青虫

我也用pthread_cond_t，不过根据我的经验，我觉得可能的话，建议你在CMyCondition中有一个计数，这样才能比较好的控制线程数量，具体的实现推荐你去看看boost库中timed_recursive_mutex的实现，很不错的参考代码。

naiza

[quote]原帖由 "菜青虫"]我也用pthread_cond_t，不过根据我的经验，我觉得可能的话，建议你在CMyCondition中有一个计数，这样才能比较好的控制线程数量，具体的实现推荐你去看看boost库中timed_recursive_mutex的实现，很不错的参考代码。[/quote 发表：

谢谢你的建议。线程的数量我可以不管业务不会太集中，以后有时间得好好研究下。我现在还是不太清楚，多个线程signal一个条件变量，一个线程wait这种模式的实现我哪里有问题

naiza

up
有人给解答下吗