不同进程间内存是不共享的,要想实现两个进程间的数据交换,可以用多进程里的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()
print(q.get())
p.join()
Pipe管道
和队列的功能差不多,实现两个进程之间数据的传递:
'''管道pipe'''
from multiprocessing import Process, Pipe
def f(conn):
conn.send('hello') #发送hello
print(conn.recv()) #收到牛逼
conn.close() #关闭
if __name__ == '__main__':
parent_conn, child_conn = Pipe() #管道会产生两个返回值
p = Process(target=f, args=(child_conn,)) #创建一个子进程
p.start()
print(parent_conn.recv()) #收到'hello'"
parent_conn.send('牛逼') #发送牛逼
p.join()
Manager管道
上面两种都是实现数据传递,现在实现数据共享,
可实现的数据类型有很多:
list, dict, Namespace, Lock, RLock, Semaphore, BoundedSemaphore, Condition, Event, Barrier, Queue, Value and Array
用法:
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)