python 进程间通信 Queue

             1
            """
             2
            进程间通信

             3
            """
             4
            import
             time

             5
            from multiprocessing import Pool, Queue, Process
 6 7 8def pull_task(q: Queue):
 9     tasks = ["任务1", "任务2", "任务3", "任务4", "任务5", "任务6", "任务7"]
10for task in tasks:
11print("正在执行", task)
12         time.sleep(1)
13        q.put(task)
141516def get_task(q: Queue):
17while True:
18try:
19print(q.get(timeout=5))
20except:
21print("任务全部完成")
22break232425if__name__ == ‘__main__‘:
26     q = Queue(5)
27     p1 = Process(target=pull_task, args=(q,))
28     p2 = Process(target=get_task, args=(q,))
29    p1.start()
30    p2.start()
31    p1.join()
32    p2.join()
3334print("over")