[请教]这段代码怎么死锁了？谢谢！~

wxp19831104

写的一个生产者，消费者模型的线程间buf，死锁了一次。不是可重现的，很偶然才出现。
void ThreadBuffer::pushFreeBuf(int sub)
{
        bool bwait=false;
        _freeMutex->acquire();
        if (_freeList.empty())
                bwait=true;
        _freeList.push(sub);
        _freeMutex->release();
        if (bwait)
                _freeCond->signal();
}

int ThreadBuffer::popFreeBuf()
{
        int sub;
        _freeMutex->acquire();
        while (_freeList.empty())
        {
                _freeCond->wait();
        }
         _freeList.pop(sub);
         _freeMutex->release();
         return sub;
}
使用的时候一个线程调用popFreeBuf取buf，另外的线程调用pushFreeBuf向里面放buf，freelist是一个队列，freeMutex和freeCond是ACE的同步变量，就是mutex和condition。
死锁的时候看，freelist不是空的，有数据，但是调用popFreeBuf的线程堵在了_freeCond->wait() 这一句，从这个现象看应该是其他线程发的信号给丢了。但是看代码，应该不可能丢啊，各位老大帮我看看，谢谢了！~

FreeGnu

btw:没用过ACE

1. 
   
2. void ThreadBuffer::pushFreeBuf(int sub)
   
3. {
   
4.       
   
5.         _freeMutex->acquire();
   
6.         if (_freeList.empty()){
   
7.                
   
8.                 _freeCond->signal();
   
9.          }else{
   
10.                 _freeList.push(sub);
    
11.         
    
12.          }
    
13.         _freeMutex->release();
    
14.       
    
15. }
    
16. 
    
17. int ThreadBuffer::popFreeBuf()
    
18. {
    
19.         int sub;
    
20.         while (_freeList.empty())
    
21.         {
    
22.                 _freeCond->wait();
    
23.         }
    
24.         _freeMutex->acquire();
    
25.          _freeList.pop(sub);
    
26.          _freeMutex->release();
    
27.          return sub;
    
28. }
    

复制代码

[ 本帖最后由 FreeGnu 于 2007-8-22 13:43 编辑 ]

ypxing

为什么不会丢呢?
而且你的bwait每次都重新赋false
一旦丢了一个以后,就再也不会signal了
wait会一直等着

原帖由 wxp19831104 于 2007-8-22 11:51 发表
写的一个生产者，消费者模型的线程间buf，死锁了一次。不是可重现的，很偶然才出现。
void ThreadBuffer::pushFreeBuf(int sub)
{
        bool bwait=false;
        _freeMutex->acquire();
        if (_freeList.empty())
...

web_surf

你wait时，_freeMutex被锁住了。这时候，如果ThreadBuffer::pushFreeBuf(int sub)再加锁_freeMutex时，必须等待, 所以就执行不了signal。 都这样了，不死锁才怪。

ypxing

condition变量会自动释放掉锁的

btw 我也没有用过ACE

原帖由 web_surf 于 2007-8-22 13:00 发表
你wait时，_freeMutex被锁住了。这时候，如果ThreadBuffer::pushFreeBuf(int sub)再加锁_freeMutex时，必须等待, 所以就执行不了signal。 都这样了，不死锁才怪。

tinywind

在特定的顺序下signal会被丢弃,比如调用次序如下
    producer                            comsumer
1  release
2                                            acquire
3                                            is empty?
4  signal
5                                            wait

第4步的signal因为没有thread在waiting所以丢失，而comsumer仍然认为队列为空

wxp19831104

问题是第一个signal不会丢啊。bwait是个局部变量，初始化为false，他在mutex同步的区域里访问freeList，如果是empty就肯定会发一个signal，这个信号不会丢的啊。。

wxp19831104

condition在wait的时候，是会自动释放锁的。
ACE的condition和Mutex就是简单的封装了pthread的同步函数。

wxp19831104

如果producer release了，那么就不会是empty了啊。。所以consumer应该不会wait，直接取数据的啊。。。

tinywind

想错了，删掉:wink:

[ 本帖最后由 tinywind 于 2007-8-22 16:26 编辑 ]