Python 进程操作之进程间通过队列共享数据,队列Queue简单示例
作者:houyanhua1 时间:2023-06-01 12:17:58
本文实例讲述了Python 进程操作之进程间通过队列共享数据,队列Queue。分享给大家供大家参考,具体如下:
队列中的数据是放在内存中的,可以通过分布式缓存redis优化队列。
demo.py(进程通过队列共享数据):
import multiprocessing
def download_from_web(q):
"""下载数据"""
# 模拟从网上下载的数据
data = [11, 22, 33, 44]
# 向队列中写入数据
for temp in data:
q.put(temp) # 队列中写数据,队列满了会阻塞。 put_nowait() 队列满了会抛异常
print("---下载器已经下载完了数据并且存入到队列中----")
def analysis_data(q):
"""数据处理"""
waitting_analysis_data = list()
# 从队列中获取数据
while True:
data = q.get() # 队列中读数据,队列空了会阻塞。 get_nowait() 队列空了会抛异常
waitting_analysis_data.append(data)
if q.empty(): # 队列是否为空。 q.full() 队列是否满了。
break
# 模拟数据处理
print(waitting_analysis_data)
def main():
# 1. 创建一个队列 (先进先出)
q = multiprocessing.Queue(10) # 最多放10个数据。 如果不指定长度,默认最大(和硬件相关)
# 2. 创建多个进程,将队列的引用当做实参进行传递
p1 = multiprocessing.Process(target=download_from_web, args=(q,))
p2 = multiprocessing.Process(target=analysis_data, args=(q,))
p1.start()
p2.start()
if __name__ == "__main__":
main()
运行结果:
---下载器已经下载完了数据并且存入到队列中----
[11, 22, 33, 44]
希望本文所述对大家Python程序设计有所帮助。
来源:https://blog.csdn.net/houyanhua1/article/details/84331397
标签:Python,进程,队列
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
讲解MaxDB数据库和MySQL的数据库的主要差别
2012-02-25 20:04:34
python如何实现API的调用详解
2023-12-26 18:24:07
![](https://img.aspxhome.com/file/2023/6/133416_0s.png)
手把手带你用python爬取小姐姐私房照
2022-04-09 16:02:04
![](https://img.aspxhome.com/file/2023/0/92320_0s.jpg)
JS实现获取数组中最大值或最小值功能示例
2024-05-02 16:15:26
![](https://img.aspxhome.com/file/2023/3/132863_0s.png)
MYSQL事务教程之Yii2.0商户提现功能
2024-01-21 10:05:46
python实现图片加文字水印OPenCV和PIL库
2021-02-04 19:29:09
![](https://img.aspxhome.com/file/2023/5/131545_0s.jpg)
Sql Server使用cursor处理重复数据过程详解
2024-01-27 09:01:35
Python快速生成定制化的Word(docx)文档
2022-04-27 12:33:06
![](https://img.aspxhome.com/file/2023/8/75298_0s.png)
Python Asyncio模块实现的生产消费者模型的方法
2022-02-10 16:13:49
Centos7 安装mysql 8.0.13(rpm)的教程详解
2024-01-19 04:52:14
python 美化输出信息的实例
2022-04-15 09:53:54
![](https://img.aspxhome.com/file/2023/7/79757_0s.jpg)
Python 'takes exactly 1 argument (2 given)' Python error
2022-04-19 00:26:05
mysql之TIMESTAMP(时间戳)用法详解
2024-01-13 16:06:42
![](https://img.aspxhome.com/file/2023/6/65286_0s.png)
php中获取指定IP的物理地址的代码(正则表达式)
2023-11-23 07:04:36
![](https://img.aspxhome.com/file/2023/1/56411_0s.png)
打印出python 当前全局变量和入口参数的所有属性
2022-09-01 07:06:51
js遍历详解(forEach, map, for, for...in, for...of)
2024-04-29 13:20:06
Python 排序最长英文单词链(列表中前一个单词末字母是下一个单词的首字母)
2023-08-26 16:08:33
Python基于内置函数type创建新类型
2023-11-18 10:00:29
全面解读Python Web开发框架Django
2022-06-24 19:41:45
IE中伪类:hover的使用及BUG
2007-05-11 17:04:00