进程通讯

import multiprocessing
import queue
def foo(num,num2,q):
    num2 +=444
    num+=1
    num+=1
    q.put((num,num2))  #  可以传数据


if __name__ == '__main__':
    # q = queue.Queue()  # 创建的是线程队列
    q = multiprocessing.Queue()  # 进程队列
    num = 1
    num2 = 3
    p = multiprocessing.Process(target=foo,args=(num,num2,q))
    p.start()
    print(q.get()[1])
    # print(id(q))
    # print(q.get())
    # print(q.get())
输出：
447

管道：

import time
from multiprocessing import Pipe,Process



def f(conn):
    conn.send('hello')
    time.sleep(2)
    response = conn.recv()
    print('response',response)
    conn.close()
    print('q_id',id(conn))

if __name__ == '__main__':
    parent_conn,child_conn = Pipe()
    p = Process(target=f,args=(child_conn,))
    p.start()
    print(parent_conn.recv())
    parent_conn.send('who n你是 you')
输出：
hello
response who n你是 you
q_id 62791536

进程信息共享》

from multiprocessing import Manager,Process


def add(a,b,c):
    a['1'] = 'hello'
    a[c] = 1
    b.append(1000)
    print(c)

if __name__ == '__main__':
    with Manager() as f:
        dict_f = f.dict()
        l = f.list(range(5))
        l_lsit = []
        for i in range(10):
            p = Process(target=add,args=(dict_f,l,i))
            p.start()
            l_lsit.append(p)
        for i in l_lsit:
            i.join()
        print(dict_f)
        print(l)
输出：
1
0
2
3
5
4
6
7
8
9
{'1': 'hello', 1: 1, 0: 1, 2: 1, 3: 1, 5: 1, 4: 1, 6: 1, 7: 1, 8: 1, 9: 1}
[0, 1, 2, 3, 4, 1000, 1000, 1000, 1000, 1000, 1000, 1000, 1000, 1000, 1000]