Python
pythonfrom multiprocessing import Queue, Manager, Process
import time
def process1(queuex: Queue):
while True:
queuex.put("dasfdsa")
time.sleep(1)
def process2(queuex: Queue):
while True:
if not queuex.empty():
path = queuex.get()
print(path)
if __name__ == '__main__':
manager = Manager()
dataq = manager.Queue()
p1 = Process(target=process1, args=(dataq,))
p2 = Process(target=process2, args=(dataq,))
p1.start()
p2.start()
p1.join()
p2.join()
本文作者:Dong
本文链接:
版权声明:本博客所有文章除特别声明外,均采用 CC BY-NC。本作品采用《知识共享署名-非商业性使用 4.0 国际许可协议》进行许可。您可以在非商业用途下自由转载和修改,但必须注明出处并提供原作者链接。 许可协议。转载请注明出处!