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