进程队列queue
2021/7/2 7:21:16
本文主要是介绍进程队列queue,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
进程队列queue
-
特点
- 能够实现进程之间的通信
- 数据安全
- 先进先出
-
实现原理
-
基于管道+锁
-
管道基于文件级别的socket+pickle实现的
-
from multiprocessing import Process from multiprocessing import Queue def f_put(q): for i in range(4): q.put(f'hello{i}') def f_get(q): for i in range(5): if q==None:break print(q.get()) if __name__ == '__main__': queue=Queue() f1=Process(target=f_put,args=(queue,)) f1.start() f2=Process(target=f_get,args=(queue,)) f2.start() f1.join() queue.put(None)
-
这篇关于进程队列queue的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-09-10RabbitMQ教程:初学者指南
- 2024-09-10RabbitMQ教程:初学者指南
- 2024-09-01Kafka事务实现原理
- 2024-08-09KubeSphere 部署 Kafka 集群实战指南
- 2024-07-24百行代码实现 Kafka 运行在 S3 之上
- 2024-07-18如何使用观测云监测 AutoMQ 集群状态
- 2024-07-18活动回顾 | AutoMQ 联合 GreptimeDB 共同探讨新能源汽车数据基础设施
- 2024-07-15AutoMQ vs Kafka: 来自小红书的独立深度评测与对比
- 2024-07-15AutoMQ 生态集成 Kafdrop-ui
- 2024-07-15AutoMQ 与蚂蚁数科达成战略合作