python process,queue

#-*- coding:utf-8 -*-
from multiprocessing import Process,Queue
import os,time,random
def write(q):
for value in ['A','B','C']:
print  'Put %s to queue...and Ospid is %s'%(value,os.getpid())
q.put(value)
time.sleep(random.random())
def read(q):
while True:
value = q.get(True)
print 'Get %s from queue.and Ospid is %s'%(value,os.getpid())

if __name__ == '__main__':
q=Queue()
pw = Process(target=write,args=(q,))
pr = Process(target=read,args=(q,))
pw.start()
pr.start()
pw.join()
pr.terminate()
print 'Main processes is 'and os.getpid()

结果：

Put A to queue...and Ospid is 7556
Get A from queue.and Ospid is 7324
Put B to queue...and Ospid is 7556
Get B from queue.and Ospid is 7324
Put C to queue...and Ospid is 7556
Get C from queue.and Ospid is 7324
7380