來自隊列中生產者消費者的另一個類的線程

Question

我想實現一個Consumer Producer實現。我還沒有實現消費者，因爲我與製作人有問題。目的是在互聯網上下載一些文件。線程是在自定義對象的方法內部啓動的。線程是子類化threading.Thread的對象。下面是代碼

downloader_thread.py

from threading import Thread 

import time 


class Downloader(Thread): 
    def __init__(self, queue, out_queue): 
     super(Downloader, self).__init__() 
     self.queue = queue 
     self.out_queue = out_queue 

    def run(self): 
     while True: 
      page = self.queue.get() 
      if page: 
       print "Simulating download" 
       print "Downloading page ", page 
       time.sleep(3) 
       self.out_queue.put(page) 

      self.queue.task_done() 

main_class.py

from Queue import Queue 

from downloader_thread import Downloader 


class Main(object): 
    def __init__(self): 
     self.queue = Queue(0) 
     self.out_queue = Queue(0) 
     self.threads = [] 
     self.max_threads = 5 

    def download(self): 
     page = 1 
     for i in range(self.max_threads): 
      download_thread = Downloader(self.queue, self.out_queue) 
      download_thread.setDaemon(True) 
      download_thread.start() 
      self.threads.append(download_thread) 

     while page < 100: 
      self.queue.put(page) 
      page += 1 

     self.queue.join() 

     for thread in self.threads: 
      thread.join() 


if __name__ == "__main__": 

    main = Main() 
    main.download() 
    while not main.out_queue.empty(): 
     print main.out_queue.get() 

問題是，啓動線程通常他們的所有五個，他們執行的是run方法，但不停止，所以一直沒有執行。我還挺新的線程和併發編程，所以請溫柔:)

的一點是要有一個消費者線程處理的代碼，同時一部分，而不是有這一點的同時，在「主要」：一部分代碼

Answer 1

你的線程永遠不會終止，因爲它們有一個無限循環的run()方法。在你download()方法你join()那些線程：

 for thread in self.threads: 
      thread.join() 

等程序被阻止。只要刪除連接，就好像你的意思是讓這些線程在程序的一生中持續存在。