使用队列的Python多线程 - 程序永远被阻塞

Question

我不确定我的程序的哪一部分是错误的。它将在两个队列的join（）调用中被阻塞。但是，如果我删除了2个加入呼叫，则该程序根本不起作用。

import threading 
    import Queue 

    queue = Queue.Queue() 
    out_queue = Queue.Queue() 

    fruits = ['apple', 'strawberry', 'banana', 'peach', 'rockmelon'] 

    class WorkerThread(threading.Thread): 
     def __init__(self, queue, out_queue): 
      threading.Thread.__init__(self) 
      self.queue = queue 
      self.out_queue = out_queue 
     def run(self): 
      print 'run' 
      while not self.queue.empty(): 
       name = self.queue.get() 
       self.out_queue.put(name) 
       self.queue.task_done() 

    def main(): 
     print 'start' 
     for i in xrange(5): 
      t = WorkerThread(queue, out_queue) 
      t.setDaemon(True) 
      t.start() 
     #populate the queue 
     for fruit in fruits: 
      queue.put(fruit) 
     queue.join() 
     out_queue.join() 
     while not out_queue.empty(): 
      print out_queue.get() 
     print 'end' 

    if __name__=='__main__': 
     main() 

在此先感谢。

Answer 1

您正在调用out_queue.join()，它等待，直到out_queue.task_done()被称为out_queue.put()被调用的次数相同。但是，你永远不会打电话out_queue.task_done()。这可以通过从不打电话out_queue.join()来解决。

编辑：此外，你开始WorkerThread s后填写queue。这意味着在您有机会插入所有元素之前，工作线程可能会运行并完成。在开始工作线程之前插入它们将解决此问题。