想问一下多线程/线程池能不能使用队列（Queue）进行通信？

如题

坻屿 2021-08-15

源自：进程与线程编程 8-1 线程池的创建及使用

收起

1回答

好帮手慕凡回答被采纳获得+3积分 2021-08-15 15:31:06

同学，你好！

多线程/线程池是可以使用队列（Queue）进行通信，祝学习愉快~

收起回答

坻屿提问者 #1

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

2021-08-15 16:38:04

同学，你好！

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

import threading,time<br>import queue<br>

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

祝学习愉快~

2021-08-15 17:22:47