我对python多线程队列有问题。我有一个脚本，其中producer从输入队列获取元素，生成一些元素并将它们放入输出队列，consumer从输出队列获取元素并打印它们：import threading

import Queue

class Producer(threading.Thread):

def __init__(self, iq, oq):

threading.Thread.__init__(self)

self.iq = iq

self.oq = oq

def produce(self, e):

self.oq.put(e*2)

self.oq.task_done()

print "Producer %s produced %d and put it to output Queue"%(self.getName(), e*2)

def run(self):

while 1:

e = self.iq.get()

self.iq.task_done()

print "Get %d from input Queue"%(e)

self.produce(e)

class Consumer(threading.Thread):

def __init__(self, oq):

threading.Thread.__init__(self)

self.oq = oq

def run(self):

while 1:

e = self.oq.get()

self.oq.task_done()

print "Consumer get %d from output queue and consumed"%e

iq = Queue.Queue()

oq = Queue.Queue()

for i in xrange(2):

iq.put((i+1)*10)

for i in xrange(2):

t1 = Producer(iq, oq)

t1.setDaemon(True)

t1.start()

t2 = Consumer(oq)

t2.setDaemon(True)

t2.start()

iq.join()

oq.join()

但是，每次我运行它时，它的工作方式都不同(给出异常，或者消费者不做任何工作)。我认为问题出在task_done()命令中，有人能解释一下bug在哪里吗？

我修改了消费类：class Consumer(threading.Thread):

def __init__(self, oq):

threading.Thread.__init__(self)

self.oq = oq

def run(self):

while 1:

e = self.oq.get()

self.oq.task_done()

print "Consumer get %d from output queue and consumed"%e

page = urllib2.urlopen("http://www.ifconfig.me/ip")

print page

现在，每个task_done()命令之后的使用者都应该连接到网站(这需要一些时间)，但它不需要，相反，如果task_done()之后的代码执行时间很短，它会运行，但如果很长，它不会运行！为什么？有人能解释一下这个问题吗？如果我把所有的东西都放在task_done()命令之前，那么我将从其他线程中阻塞队列，这已经足够愚蠢了。或者在python中的多线程有什么我遗漏的吗？