Python队列实现进程通信

之前在网络编程中学习了一种进程之间通信的方式—socket，本文介绍了进程之间另一种通信方式—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):
    #  数据处理
    waitting_analysis_data=list()
    #  从队列中获取数据
    while True:
        data=q.get()
        waitting_analysis_data.append(data)

        if q.empty():
            break
    print(waitting_analysis_data)

def main():
    #  1.创建一个队列
    q=multiprocessing.Queue()
    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()
           

运行结果可以看到两个进程通过队列联系在了一起：