擅长:python、mysql、java
<p>首先用队列初始化消费者类。在</p>
<p>然后加上queue.task\u完成()位于使用者线程类的末尾。这将告诉线程以后忽略该队列项队列.get()电话。最终,这意味着您的队列将“清空”,线程将完成其工作。在</p>
<pre><code>class consumer(threading.Thread):
def __init__(self, queue):
threading.Thread.__init__(self)
self.queue = queue
def run(self):
while queue.not_empty:
queue_ret = self.queue.get()
print("Retrieved", queue_ret)
self.queue.task_done()
# to start your threads, for example 5 threads
for i in range(5):
consumers = consumer(queue)
consumers.start()
</code></pre>