python之进程间的通信（queue，pipe，Manager）不同进程间内存是不共享的，要想实现两个进程间的数据交换，可以⽤多进程⾥的Queue来解决：
Queues
使⽤⽅法跟threading⾥的queue差不多，注意在执⾏的时候，queue是⼀个备份，⽽不是原来的queue，不过实现了数据共享。
from multiprocessing import Process, Queue
#注意这⾥要import Queue，之后的使⽤相当于备份⼀个queue，并且是⼀个同步的queue
def f(q):
q.put(25)
if __name__ == '__main__':
q = Queue()
p = Process(target=f, args=(q,))
'''实现主进程和⼦进程的通信，放⼊同⼀个队列中'''
p.start()
())
p.join()
Pipe管道
和队列的功能差不多，实现两个进程之间数据的传递:
'''管道pipe'''
from multiprocessing import Process, Pipe
def f(conn):
conn.send('hello')  #发送hello
v())  #收到⽜逼
conn.close()        #关闭
if __name__ == '__main__':
parent_conn, child_conn = Pipe()    #管道会产⽣两个返回值
p = Process(target=f, args=(child_conn,))  #创建⼀个⼦进程
p.start()
print(v())  #收到'hello'"
parent_conn.send('⽜逼')  #发送⽜逼
p.join()
Manager管道
上⾯两种都是实现数据传递，现在实现数据共享，
可实现的数据类型有很多：
,
, , , , , , , , , ,  and
⽤法：
from multiprocessing import Process, Manager
def f(d, l):
d[1] = '1'
d['2'] = 2
l.append(1)    #追加⼀个1
进程通信方式
# print(l)
if __name__ == '__main__':
d = Manager().dict()  # ⽣成⼀个字典，可在多个进程间共享和传递    l = Manager().list(range(5))  # 列表
p_list = [] #进程列表
for i in range(10):
p = Process(target=f, args=(d, l))  #循环10次每次创建⼀个进程        p.start()
p_list.append(p)    #加⼊进程列表⾥
for res in p_list:  #等所有进程结束
res.join()
print(d)
print(l)

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。