使用隊列的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。這意味着在您有機會插入所有元素之前，工作線程可能會運行並完成。在開始工作線程之前插入它們將解決此問題。