雨露计划,闫治民,权力的游戏第七季第一集下载
使用 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()
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Python 实现将numpy中的nan和inf,nan替换成对应的均值
python爬虫把url链接编码成gbk2312格式过程解析
网友评论