pthread_cond_signal发送信号时并不需要占有互斥量？

GodPig

在man pthread_cond_signal里面看到这样一句话：

It  is  not  safe to use the pthread_cond_signal() function in a signal handler that is invoked asynchronously. Even if it
       were safe, there would still be a race between the test of the Boolean pthread_cond_wait() that could not  be  efficiently
       eliminated.

看的迷迷乎乎，是不是说pthread_cond_signal不能在异步调用的信号处理程序 使用？
否则就会出现竞争？
与pthread_cond_wait()???

我想不太明白……

如果有多个线程用pthread_cond_signal向一个条件变量发送信号，是不是也会出现竞争？

谢谢！！！

群雄逐鹿

首先这样的代码不安全, 因为线程有可能被signal打断，这样就会锁死。
in signal
   mutex_lock(&m);
   ....
   mutex_unlock(&m);

in thread
   mutex_lock(&m);
   ....
   mutex_unlock(&m);

然而condition很难实现的那么单纯，不排除上述类似mutex的情况，锁死就很可能了。
这是boost 1.33中的condition signal的实现，里面也有mutex lock.

1. 
   
2. void condition_impl::notify_one()
   
3. {
   
4.     unsigned signals = 0;
   
5. 
   
6.     int res = 0;
   
7.     res = WaitForSingleObject(reinterpret_cast<HANDLE>(m_mutex), INFINITE);
   
8.     assert(res == WAIT_OBJECT_0);
   
9. 
   
10.     if (m_waiting != 0) // the m_gate is already closed
    
11.     {
    
12.         if (m_blocked == 0)
    
13.         {
    
14.             res = ReleaseMutex(reinterpret_cast<HANDLE>(m_mutex));
    
15.             assert(res);
    
16.             return;
    
17.         }
    
18. 
    
19.         ++m_waiting;
    
20.         --m_blocked;
    
21.         signals = 1;
    
22.     }
    
23.     else
    
24.     {
    
25.         res = WaitForSingleObject(reinterpret_cast<HANDLE>(m_gate), INFINITE);
    
26.         assert(res == WAIT_OBJECT_0);
    
27.         if (m_blocked > m_gone)
    
28.         {
    
29.             if (m_gone != 0)
    
30.             {
    
31.                 m_blocked -= m_gone;
    
32.                 m_gone = 0;
    
33.             }
    
34.             signals = m_waiting = 1;
    
35.             --m_blocked;
    
36.         }
    
37.         else
    
38.         {
    
39.             res = ReleaseSemaphore(reinterpret_cast<HANDLE>(m_gate), 1, 0);
    
40.             assert(res);
    
41.         }
    
42.     }
    
43. 
    
44.     res = ReleaseMutex(reinterpret_cast<HANDLE>(m_mutex));
    
45.     assert(res);
    
46. 
    
47.     if (signals)
    
48.     {
    
49.         res = ReleaseSemaphore(reinterpret_cast<HANDLE>(m_queue), signals, 0);
    
50.         assert(res);
    
51.     }
    
52. }
    
53. 
    

复制代码

lanying_wzw

顶一下，大家讨论一下