进程 4.Queue实现进程间通信
2021/12/15 7:16:42
本文主要是介绍进程 4.Queue实现进程间通信,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
Queue实现进程间通信
进程1 ---put(3)---put(2)---put(1) ↓ ↓ ↓ queue: 3 2 1 ↓ ↓ ↓ get(3)---get(2)---get(1)--- 进程2
import multiprocessing import time # 写入数据到queue def write_queue(queue): for i in range(10): if queue.full(): print('队列已满') break queue.put(i) print('已写入:',i) time.sleep(0.5) # 从queue读取数据 def read_queue(queue): while True: if queue.empty(): print('队列已空') break value = queue.get() print('已读取:',value) if __name__ == '__main__': # 创建queue queue = multiprocessing.Queue(5) # 创建多个进程 process_write = multiprocessing.Process(target=write_queue,args=(queue,)) process_read = multiprocessing.Process(target=read_queue,args=(queue,)) process_write.start() process_write.join() process_read.start() 已写入: 0 已写入: 1 已写入: 2 已写入: 3 已写入: 4 队列已满 已读取: 0 已读取: 1 已读取: 2 已读取: 3 已读取: 4 队列已空
这篇关于进程 4.Queue实现进程间通信的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-10-27[开源] 一款轻量级的kafka可视化管理平台
- 2024-10-23Kafka消息丢失资料详解:初学者必看教程
- 2024-10-23Kafka资料新手入门指南
- 2024-10-23Kafka解耦入门:新手必读教程
- 2024-10-23Kafka入门:新手必读的简单教程
- 2024-10-23Kafka入门:新手必读的简单教程
- 2024-10-23Kafka消息丢失入门:新手必读指南
- 2024-10-23Kafka消息队列入门:新手必看的简单教程
- 2024-10-23Kafka消息队列入门与应用
- 2024-10-23Kafka重复消费入门:轻松掌握Kafka重复消息处理技巧