我有一个队列和一个事件。 当事件设置为True时，我想退出循环，但循环中有一个queue.get()会一直阻塞直到队列中有东西。
当closeEvent事件标志被设置时，如何中止等待self._commandQueue.get()？
注意：我想避免依赖队列的阻塞性，并希望基于队列和事件标志的条件进行阻塞。
def _execute(self):
while not self._closeEvent.isSet():
nextCommand = self._commandQueue.get()
self._commandExecutor.execute(nextCommand)
self._commandQueue.task_done()
WaitForMultipleObjects()调用，但是Python事件和队列API并没有提供这样的功能（除非你只在Windows上使用win32api），所以如果你真的需要同时检查两个事件源，答案是“你不能，除非进行轮询（或者修补Event类以允许它）”。PriorityQueue，你可以将普通优先级的常规作业加入队列，并使用更高的优先级让额外的进程队列中止标记一旦事件发生信号。STOP = None
def _execute(self):
while 1:
nextCommand = self._commandQueue.get()[1]
if nextCommand is STOP:
break
self._commandExecutor.execute(nextCommand)
self._commandQueue.task_done()
def wait_for_stop_signal(self):
self._closeEvent.wait()
self._commandQueue.put((-1, STOP))
wait_for_stop_signal 函数，这样你就可以获得想要的结果（但会浪费一个线程，而不是轮询，根据你的使用情况选择更糟糕的选项）。Queue内部根据http://hg.python.org/cpython/file/3a1db0d2747e/Lib/Queue.py#l150使用事件。 具体来说，它使用self.not_empty事件，应用程序在尝试调用Queue.get_nowait之前也可以等待该事件。在您的队列中放置一个“魔法退出标记”。我将使用None，如果需要，您可以使用特殊的退出消息。这与使用优先级队列方法基本相同，但是 (a) 它更简单，(b) 但是队列必须清空到标记点，这可能或可能不可接受。
例如：
# Untested
# Processing thread
def run(self):
while True:
msg = self.main_queue.get()
if msg == None:
break
...do..queue..work...
def shutdown():
self.main_queue.put(None)
不要直接调用Queue.get方法。创建一个事件对象，当以下情况之一发生时触发： * 将某些内容放入队列中。 * 想要关闭队列。
不要将队列暴露给外部，而是定义一个向队列添加元素的方法：
def add_to_queue(self, msg):
self.main_queue.put(msg)
self.my_event.set() # Signal the consumer
def shutdown(self, msg):
self.quit_event.set() # Set an event / condvar / msg to indicate exit
self.my_event.set() # Signal something has happened.
def run(self)
while True:
self.my_event.wait()
if self.quit_event.is_set()
break
msg = self.main_queue.get(False) # Empty exception should not happen here
您不一定需要一个退出事件，因为您可以假设一个空队列和一个已发出信号的my_event意味着是时候退出了。尽管如此，我认为最好明确地使用适当的指示器 - 消息、事件、条件变量等。
Queue.get方法在没有参数的情况下调用时是一种阻塞方法。
根据文档：
将项目放入队列中。如果可选参数block为true且timeout为None（默认值），则必要时阻止，直到有一个空闲插槽可用。如果timeout是正数，则最多阻塞timeout秒，并在该时间内没有可用的空闲插槽时引发Full异常。否则（block为false），如果立即有一个空闲插槽，则将项目放入队列中，否则引发Full异常（在这种情况下忽略timeout）。
你需要做类似于这样的事情：
try:
# If `False`, the program is not blocked, it will throw the Queue.Empty exception.
my_data = queue.get(False)
.....Some Code......
except Queue.Empty:
my_data = None # or whatever you want
更多选项
get_nowait:
Queue.get_nowait()相当于get(False)。
使用超时:
my_data = queue.get(True, 5)。如果获取失败(没有获取到任何内容)，它将尝试获取5秒钟，然后引发相同的异常Queue.Empty。