# -*- coding: utf-8 -*-
from multiprocessing import Process, Queue
import os, time, random# 写数据进程执行的代码:
def write(q):print('Process to write: %s' % os.getpid())for value in ['A', 'B', 'C']:print('Put %s to queue...' % value)q.put(value)time.sleep(random.random())# 读数据进程执行的代码:
def read(q):print('Process to read: %s' % os.getpid())while True:value = q.get(True)print('Get %s from queue.' % value)if __name__=='__main__':# 父进程创建Queue，并传给各个子进程：q = Queue()pw = Process(target=write, args=(q,))pr = Process(target=read, args=(q,))# 启动子进程pw，写入:pw.start()# 启动子进程pr，读取:pr.start()# 等待pw结束:pw.join()# pr进程里是死循环，无法等待其结束，只能强行终止:pr.terminate()
执行代码后理应打印出结果
Process to write: 85994
Put A to queue...
Process to read: 85995
Get A from queue.
Put B to queue...
Get B from queue.
Put C to queue...
Get C from queue.但是如果你遇到下面这种情况，解决办法是在终端命令工具中运行： python 文件名.py
Process to write: 85926
Put A to queue...
Put B to queue...
Put C to queue...