多線程 blocking queue

https://paste.ubuntu.com/p/cWsFNYcGpQ/
先寫了MyQueue1 用一個condition
consumer thread透過condition判斷que empty ,就wait, release lock
producer thread透過同一個condition 取得lock, 放東西到que, and notify consumer

但是看了python and java source code
都是用兩個condition (not_empty / not_full)
為什麼要這麼做呢？我的作法應該也行得通，難道是效率問題？
看不透，請大家解疑，感謝

我认为主要是性能。 楼主的一个条件的情况中 self.condition.notify() 应该改成notifyAll， 不然可能被同种等待条件的线程占有后失效。  然后降低notifyAll开销的办法就是分开为两个条件。

yuqinlear 发表于 2019-4-26 08:34
我认为主要是性能。 楼主的一个条件的情况中 self.condition.notify() 应该改成notifyAll， 不然可能被同种 ...

可以解釋一下為什麼是性能嗎？為什麼用兩個condition (not_full & not_empty)
我也猜測是性能，但實在想不是很清楚。
兩個condition是怎麼運作的？

Python source code 裡面這樣寫道
https://paste.ubuntu.com/p/5P3dZ35yt4/
```
        # Notify not_empty whenever an item is added to the queue; a
        # thread waiting to get is notified then.
        self.not_empty = threading.Condition(self.mutex)

        # Notify not_full whenever an item is removed from the queue;
        # a thread waiting to put is notified then.
        self.not_full = threading.Condition(self.mutex)
```

sean72kimo 发表于 2019-4-26 09:03
可以解釋一下為什麼是性能嗎？為什麼用兩個condition (not_full & not_empty)
我也猜測是性能，但實在想 ...

只用一个条件的情况，所有线程被注册在一个管程中(抢一个话筒）: 当empty()的时候consumer线程被阻塞，而producer在queue中放入元素后，notify唤醒的可能是另一个producer(因为这个是不可定的），进而producer产出遇到队列容量限制后阻塞造成死锁。  解决办法，使用notifyAll唤醒所有线程保障consumer进入打破僵局。 notifyAll需要唤醒所有线程，所有线程都要尝试进入critical section很可能再次被阻塞, 光看下这context switch就是个明显的开销。
引入两个条件后，producer，consumer分别被注册在不同管程(各自一个话筒）， producer完事后唤醒单个consumer去获取其相应管程。

yuqinlear 发表于 2019-4-26 09:44
只用一个条件的情况，所有线程被注册在一个管程中(抢一个话筒）: 当empty()的时候consumer线程被阻塞，而 ...

按照你描述的情況：
```
当empty()的时候consumer线程被阻塞，而producer在queue中放入元素后，notify唤醒的可能是另一个producer(因为这个是不可定的），
```
P1完事，喚醒了P2，但是P2會在 while loop檢查que是否滿了，發現滿了，回到condition.wait() 釋放鎖。
為什麼會死鎖呢？