码迷,mamicode.com
首页 > 编程语言 > 详细

【python】多任务(2. 进程)

时间:2019-10-31 18:49:23      阅读:89      评论:0      收藏:0      [点我收藏+]

标签:nal   web   empty   传递   multi   pen   数据下载   ssi   int   

进程间通信 Queue

import  multiprocessing


def download_from_web(q):
    # 模拟从网上下载数据
    data = [11, 22, 33, 44]
    for i in data:
        q.put(i)
    print("---数据下载已写入到队列---")


def analysis_data(q):
    waitting_analysis_data = list()
    while not q.empty():
        waitting_analysis_data.append(q.get())
    print(str(waitting_analysis_data) + " <<< 数据拼接完毕")


def main():

    # 1. 创建一个队列
    q = multiprocessing.Queue(4)
    # 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】多任务(2. 进程)

标签:nal   web   empty   传递   multi   pen   数据下载   ssi   int   

原文地址:https://www.cnblogs.com/liudianer/p/11772706.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!