プロデューサの別のクラスのスレッドキューを持つコンシューマ

Question

コンシューマプロデューサの実装用に実装したいと思います。私はプロデューサーに問題があるので、まだ消費者を実装していません。目的は、インターネットにいくつかのファイルをダウンロードすることです。スレッドは、カスタムオブジェクトのメソッド内で開始されます。スレッドはスレッディングをサブクラス化するオブジェクトです。ここでは、通常、それらのすべての5つは、彼らはrunメソッドであるものを行う

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() 

問題は、スレッドが開始されていることであるコード

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あり、しかし、停止しないので、whileは決して実行されません。私はちょっとスレッドと並行プログラミングのために少し新しくなっています。だから穏やかにしてください:) メイン "の中にこれを置くのではなく、コードのwhile部分を扱う消費者スレッドを持つことがポイントです。コード

Answer 1

無限ループのあるrun()メソッドがあるため、スレッドは終了しません。あなたのdownload()方法あなたのスレッドにjoin()で：

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

ので、プログラムがブロックされています。プログラムの存続期間中にそれらのスレッドが永続することを意味しているように、結合を削除するだけです。