2021-03-15Python之Queue的使用

概述序列代码：fromthreadingimportThread,current_threadimporttimeimportrandomfromqueueimportQueuequeue=Queue(5)classProductThread(Thread):defrun(self):name=current_thread().getName()nums=range(100)globalqueu

序列代码：

from threading import Thread,current_threadimport timeimport randomfrom queue import Queuequeue = Queue(5)class ProductThread(Thread):    def run(self):        name = current_thread().getname()        nums = range(100)        global queue        while True:            num = random.choice(nums)            queue.put(num)            print('生产者 %s 生产了数据 %s' %(name,num))            t = random.randint(1,3)            time.sleep(t)            print('生产者 %s 睡眠了 %s' %(name,t))class ConsumerThread(Thread):    def run(self):        name = current_thread().getname()        global queue        while True:            num = queue.get()            queue.task_done()            print('消费者 %s 消耗了数据 %s' %(name,num))            t = random.randint(1,5)            time.sleep(t)            print('消费者 %s 睡眠了 %s ' %(name,t))p1 = ProductThread(name='p1')p1.start()c1 = ConsumerThread(name='c1')c1.start()c2 = ConsumerThread(name='c2')c2.start()

总结

以上是内存溢出为你收集整理的2021-03-15 Python之Queue的使用全部内容，希望文章能够帮你解决2021-03-15 Python之Queue的使用所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。