Python的重構與線程和隊列

Question

我試圖調整自己的代碼，第一個版本是here

我想是運行兩個對象同時

from queue import Queue 
from threading import Thread 
from html.parser import HTMLParser 
import urllib.request 

NUMBER_OF_THREADS = 3 

HOSTS = ["http://yahoo.com", "http://google.com", "http://ibm.com"] 


class MyHTMLParser(HTMLParser): 
    def handle_starttag(self, tag, attrs): 
     print("Start tag:", tag) 
     for attr in attrs: 
      print("\tattr:", attr) 


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

     def run(self): 
      while True: 
       for host in HOSTS: 
        url = urllib.request.urlopen(host) 
        content = str(url.read(4096))      
        queue.put(content) 


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


     def run(self): 
      while True: 
       item = queue.get() 
       parser = MyHTMLParser() 
       new_con = parser.feed(item) 
       print(new_con) 
       queue.task_done() 


if __name__ == '__main__': 
    queue = Queue() 

    p = ProducerThread(queue) 
    c = ConsumerThread(queue) 
    p.start() 
    c.start() 

當我從終端運行的代碼沒有output.What我應該改變？

Answer 1

Unindent run方法，以便他們不在__init__方法。

但是，請注意，你幾乎肯定不希望那些永遠循環;刪除while True。