进程 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-05-29AutoMQ 产品动态 | 企业版正式上线阿里云、AWS 中国区云市场
- 2024-05-29盘点 AutoMQ 深度使用的阿里云云原生技术
- 2024-05-29盘点 AutoMQ 深度使用的阿里云云原生技术
- 2024-05-29AutoMQ 社区双周精选第十期
- 2024-05-08「布道师系列文章」解析 AutoMQ 对象存储中的文件存储格式
- 2024-05-08「布道师系列文章」小红书黄章衡:AutoMQ Serverless 基石-秒级分区迁移
- 2024-05-08AutoMQ 系统测试体系揭秘
- 2024-03-14AutoMQ 携手阿里云共同发布新一代云原生 Kafka,帮助得物有效压缩 85% Kafka 云支出!
- 2024-02-22kafka partitioner
- 2024-01-24AutoMQ生态集成 - 将数据从 AutoMQ Kafka 导入 RisingWave 数据库