Python 线程应用程序未终止

Question

我有一个简单的Python应用程序，如果我使用queue.join()，它不会终止。下面是代码:

import threading
import Queue

q = Queue.Queue()

for i in range(5):
    q.put("BLAH")

def worker():
    while True:
         print q.qsize()
         a = q.get()
         print q.qsize()
         q.task_done()
         print q.qsize()


for i in range(2):
    t = threading.Thread(target=worker())
    t.daemon = True
    t.start()

q.join()

我还创建了一个看门狗线程，它打印 threading.enumerate()，然后休眠 2 秒。剩下的唯一线程是 MainThread，队列大小实际上为 0。该脚本永远不会终止。我必须ctrl + z，然后杀死它。这是怎么回事？

Answer 1

t = threading.Thread(target=worker)

您想要传递对工作函数的引用，您不应该调用它。