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,进程,队列
0
投稿

猜你喜欢

  • Python限制内存和CPU使用量的方法(Unix系统适用)

    2023-08-02 08:41:44
  • python基于gevent实现并发下载器代码实例

    2024-01-01 00:31:53
  • position两三事

    2009-02-16 15:23:00
  • 网页制作 JSP与ASP 的比较

    2005-08-10 16:00:00
  • css行高:line-height属性详解

    2008-06-24 11:42:00
  • 一个div层打开显示效果 js

    2008-05-19 12:35:00
  • 通过asp程序来创建access数据库

    2011-04-02 11:17:00
  • 基于php+mysql的期末作业小项目(学生信息管理系统)

    2023-06-13 00:39:34
  • 用PHP编写每周签到功能以提高用户参与度

    2023-05-27 17:24:54
  • 关于Python中object类特殊方法的解释

    2023-08-31 22:19:24
  • MySQL数据库常见的出错代码及出错信息

    2008-05-27 12:29:00
  • 一个较新的ASP后门服务端实现代码

    2011-02-16 10:41:00
  • asp下查询xml的实现代码

    2011-04-19 10:37:00
  • CSS和HTML与前端技术层图示

    2010-04-05 21:54:00
  • 常用的匹配正则表达式和实例

    2008-06-07 09:19:00
  • 使用组件来保护你的ASP代码

    2008-06-03 13:47:00
  • 用mysql做站点时怎样记录未知错误的发生

    2009-01-14 13:16:00
  • java-jsp springmvc-controller 传值到页面的方法

    2023-06-16 18:19:52
  • Python获取当前函数名称方法实例分享

    2023-12-22 01:16:57
  • python实现图片文件批量重命名

    2023-08-10 03:39:57
  • asp之家 网络编程 m.aspxhome.com