生产者消费者

生产者消费者,第1张

生产者消费者

生产者就是只做一件事就是生产一个资源放入管道,供消费者消费,消费者也知做一件事,就是从管道中取出一个资源进行消费
代码片段:

import queue
import time
#创建一个队列
import threading
q = queue.Queue()
def producer(args):
    while True:
        time.sleep(2)
        q.put(args)
        print("线程%s生产了一个资源"%args)

def consumer(args):
    while True:
        time.sleep(2)
        v1 = q.get()
        print("线程%s取走了一个资源"%args)

#创建三个线程作为生产者生产资源
for i in range(1,4):
    t = threading.Thread(target=producer,args=(i,))
    t.start()

#创建两个线程作为消费者消费资源
for i in range(1,3):
    t = threading.Thread(target=consumer,args=(i,))
    t.start()

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5688154.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-17
下一篇 2022-12-17

发表评论

登录后才能评论

评论列表(0条)

保存