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

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

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

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')

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