发布于2019-08-07 16:28 阅读(893) 评论(0) 点赞(2) 收藏(0)
使用 multiprocessing 里的 Queue()
import multiprocessing def download_from_web(q): """下载数据""" # 模拟从网上下载的数据 data = [11, 22, 33, 44] # 向队列中写入数据 for temp in data: q.put(temp) print("下载器已经下载完了数据并且存入到队列中") def analysis_data(q): """数据处理""" waiting_analysis_data = list() while True: # 从队列中获取数据 data = q.get() waiting_analysis_data.append(data) # 判断队列是否为空 if q.empty(): break # 模拟数据处理(如单核CPU只能打印[11]) print(waiting_analysis_data) def main(): # 1.创建一个队列 q = multiprocessing.Queue() # 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()
作者:74873487
链接:https://www.pythonheidong.com/blog/article/11528/b0832ee9790beff729b0/
来源:python黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容:(最多支持255个字符)
---无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事,而不是让内心的烦躁、焦虑,坏掉你本来就不多的热情和定力
Copyright © 2018-2021 python黑洞网 All Rights Reserved 版权所有,并保留所有权利。 京ICP备18063182号-1
投诉与举报,广告合作请联系vgs_info@163.com或QQ3083709327
免责声明:网站文章均由用户上传,仅供读者学习交流使用,禁止用做商业用途。若文章涉及色情,反动,侵权等违法信息,请向我们举报,一经核实我们会立即删除!