进程间的通信----队列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)

        print(waitting_analysis_data)

        # q.empty()队列是否为空，q.full()队列是否满了
        if q.empty():
            break


def main():
    # 创建队列
    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()

数据下载完毕。。。。
[11]
[11, 22]
[11, 22, 33]
[11, 22, 33, 44]