python中的键盘中断阻塞队列

Queue 对象具有这种行为,因为它们使用 Condition 对象构成 threading 模块。所以你的解决方案真的是唯一的方法。

但是,如果你真的想要 排队 方法,您可以使用monkeypatch 排队 班级。例如:

def interruptable_get(self):
    while True:
        try:
            return self.get(timeout=1000)
        except Queue.Empty:
            pass
Queue.interruptable_get = interruptable_get

你可以这么说

q.interruptable_get()

而不是

interruptable_get(q)

尽管monkeypatching在类似的情况下通常不受Python社区的支持,因为常规函数似乎也很好。

这可能根本不适用于您的用例。但我已经成功地在几个案例中使用了这个模式:(粗略的,可能是小车,但你明白了)。

STOP = object()

def consumer(q):
    while True:
        x = q.get()
        if x is STOP:
            return
        consume(x)

def main()
    q = Queue()
    c=threading.Thread(target=consumer,args=[q])

    try:
        run_producer(q)
    except KeybordInterrupt:
        q.enqueue(STOP)
    c.join()