通过队列完成进程间的通信

multiprocessing


(q):
    data = []

    temp data:
        q.put(temp)
    ()


(q):
    waitting_analysys_data = ()
    :
        data = q.get()
        waitting_analysys_data.append(data)

        q.empty():
            (waitting_analysys_data)


():
    q = multiprocessing.Queue()

    p1 = multiprocessing.Process(=download_form_web=(q))
    p2 = multiprocessing.Process(=analysys_data=(q))

    p1.start()
    p2.start()


__name__ == :
    main()

分享题目：通过队列完成进程间的通信
转载注明：http://shouzuofang.com/article/igsejh.html