processqueue.py 文件源码

def demo():
    q = multiprocessing.JoinableQueue()  # ??????????
    cons_p = multiprocessing.Process(target=consumer, args=(q, ))
    cons_p.daemon = True
    cons_p.start()

    seq = [1, 2, 3, 4, 5]
    producer(seq, q)

    q.join()  # ?????????????????????????