两进程之间的通信（管道实现）

import multiprocessing
import time
def after(conn):while True:print('接收到数据：',conn.recv())time.sleep(1)def before(conn):while True:data = [42,None,34,'hello']conn.send(data)print('正在发送' ,data)time.sleep(1)before_conn,after_conn = multiprocessing.Pipe()
p1 = multiprocessing.Process(target=after,args=(after_conn,))
p1.start()
p2 = multiprocessing.Process(target=before,args=(before_conn,))
p2.start()

两进程之间的通信（管道实现）

import multiprocessing
import time
def after(conn):while True:print('接收到数据：',conn.recv())time.sleep(1)def before(conn):while True:data = [42,None,34,'hello']conn.send(data)print('正在发送' ,data)time.sleep(1)before_conn,after_conn = multiprocessing.Pipe()
p1 = multiprocessing.Process(target=after,args=(after_conn,))
p1.start()
p2 = multiprocessing.Process(target=before,args=(before_conn,))
p2.start()