from multiprocessing import Manager,Pool

def wp(q):

    for i in "WANG":

        q.put(i)

        print("写入：%s"%i)

def rd(q):

    while True:

        if not q.empty():

            print("读取：%s"%q.get())

if __name__=="__main__":

    #创建队列,在进程池中专用方法,使用Manager中的Queue来初始化

    qu = Manager().Queue()

    #创建进程池,不做限制

    po = Pool()

    #创建写入进程

    wp = po.apply(func=wp,args=(qu,))

    #创建读取进程

    rd = po.apply(func=rd,args=(qu,))

    #关闭进程池

    po.close()

写入：W

写入：A

写入：N

写入：G

读取：W

读取：A

读取：N

读取：G