多进程之间的通信

 1 from multiprocessing import*
 2 from time import sleep
 3 #定义写入的方法
 4 def write(q):
 5     a = ['a','b','c','d']
 6     for i in a:
 7         print('开始写入的值：%s'%i)
 8         q.put(i)
 9         sleep(1)
10 
11 def reader(q):
12     for i in range(q.qsize()):
13         print('读取到的值：%s'%q.get())
14         sleep(1)
15 
16 if __name__ == '__main__':
17     #创建队列
18     q = Queue()
19     #创建进程
20     pw = Process(target=write,args=(q,))
21     pr = Process(target=reader,args=(q,))
22     pw.start()
23     pw.join()
24     pr.start()
25     pr.join()

1 开始写入的值：a
2 开始写入的值：b
3 开始写入的值：c
4 开始写入的值：d
5 读取到的值：a
6 读取到的值：b
7 读取到的值：c
8 读取到的值：d

正是江南好风景