1回答

bobby

2020-02-05

你把完整的代码贴一下 我这里尝试一下

0

1

慕标1049315

import time # multiprocessing里的Queue可用于进程间通信，但不能用于进程池通信 from multiprocessing import Process, Queue, Manager, Pool, Pipe # 这个Queue只能用于多线程通信 # from queue import Queue def producer(queue): queue.put(1) time.sleep(2) def consumer(queue): time.sleep(2) data = queue.get() print(data) """ if __name__ == "__main__": queue = Queue(10) my_producer = Process(target=producer,args=(queue,)) my_comsumer = Process(target=consumer,args=(queue,)) my_producer.start() my_comsumer.start() my_producer.join() my_comsumer.join()

2020-02-07

共1条回复