想问一下多线程/线程池能不能使用队列(Queue)进行通信?

想问一下多线程/线程池能不能使用队列(Queue)进行通信?

正在回答

登陆购买课程后可参与讨论,去登陆

1回答

同学,你好!

​多线程/线程池是可以使用队列(Queue)进行通信,祝学习愉快~

  • 坻屿 提问者 #1

    可不可以写一下具体的在多线程/线程池中使用队列的代码呢?

    2021-08-15 16:38:04
  • 好帮手慕凡 回复 提问者 坻屿 #2

    同学,你好!

    可以参考以下代码,思考队列在在多线程中的使用:

    ​import threading,time
    import queue
    #创建队列最大长度为10
    q = queue.Queue(maxsize=50)
    #创建生产者
    def Producer(name):
    count = 1
    while True:
    #把生产的骨头放入队列
    q.put('骨头%s' % count)
    print('%s生产了骨头'%name, count)
    count += 1
    time.sleep(1)
    #创建消耗者
    def Consumer(name):
    while True:
    #取出骨头吃掉
    print('[%s] 取到[%s] 并且吃了它...'%(name,q.get()))
    time.sleep(1)
    #创建线程
    p = threading.Thread(target=Producer,args=('慕慕',))
    c = threading.Thread(target=Consumer,args=('大黄',))
    c1 = threading.Thread(target=Consumer,args=('大黑',))
    #开启线程
    c.start()
    c1.start()
    p.start()

    祝学习愉快~

    2021-08-15 17:22:47
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师