Python中的公平信號量

Question

Python中是否可以有一個公平的信號量，它可以保證阻塞線程按照他們所謂的acquire()的順序被解除阻塞？

Answer 1

您可能需要從其他運動部件構建一個。例如，創建一個Queue.Queue()，每個聽衆發佈一個全新的Event()，然後等待。當需要喚醒其中一個等待線程時，彈出隊列中等待時間最長的項目 - 它將成爲這些事件對象之一 - 並通過event.set()釋放線程。很顯然，你也可以在等待進程中使用信號量，但是我喜歡Event的語義，因爲它明顯只會發生一次，而信號量的語義是它的值可以支持許多等待線程。

要設置系統啓動：

import Queue 
big_queue = Queue.Queue() 

然後，等待：

import threading 
myevent = threading.Event() 
big_queue.put(myevent) 
myevent.wait() 

並釋放等待線程：

event = big_queue.get() 
event.set() 

我想的弱點這種方法是，執行set/release的線程必須等待一個等待的線程出現，而一個真正的semap即使沒有人等待，Hore會讓幾個發佈進行下去嗎？

Answer 2

利用具有布蘭登解決「公平旗語」的問題，它可能是看的障礙，一個候車點線程到達，然後在同一時間發佈了相關的問題很有用：http://docs.python.org/py3k/whatsnew/3.2.html#threading