Java教程

使用队列实现进程之间的数据共享

本文主要是介绍使用队列实现进程之间的数据共享,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

如何创建多个进程?
进程之间如何实现通信?
使用队列实现进程之间的数据共享!!!

from multiprocessing import Queue,Process
import time,random

list1 = ["Java","Python","C","Go"]

def write(queue):
	for value in list1:
		print(f"正在向队列中添加数据{value}")
		queue.put(value)
		time.sleep(random.random())

def read(queue):
	while True:
		if not queue.empty():
			value = queue.get()
			print(f"从队列中读取的数据为{value}")
			time.sleep(random.random())
		else:
			break

queue = Queue()
write_data = Process(target=write,args=(queue,))
read_data = Process(target=read,args=(queue,))

if __name__ == '__main__':
	write_data.start()
	write_data.join()

	read_data.start()
	read_data.join()

	print('OK')
这篇关于使用队列实现进程之间的数据共享的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!