进程锁

 在同一时间使用多个进程同时运行，可能导致反馈数据顺序是乱的，为保证得到理想的数据顺序,就需要添加一把锁以控制数据的顺序输出。

from multiprocessing import Manager,Pipe,Process,os, Lock

def t(lock,d,l):

    lock.acquire()  # 加锁

    try:

        d[os.getpid()] = os.getpid()

        l.append(os.getpid())

    finally:

        lock.release()  # 释放

if __name__ =='__main__':

    # parent_cnn, child_cnn = Pipe()  # 管道生成两个实例

    lock = Lock()

    with Manager() as manager:

        d = manager.dict()

        l = manager.list(range(10)) # 声明一个[0,1,2,3....,9]的列表

        p_list = []

        for i in range(5):

            p = Process(target=t,args=(lock, d,l))

            # p.daemon = True

            p.start()

            p_list.append(p)

        for j in p_list:

            j.join()

        print d # {11160: 11160, 11161: 11161, 11162: 11162, 11163: 11163, 11164: 11164}

        print l # [0, 1

# 进程池

from multiprocessing import Process, Pool, Lock

import os, time

def f(i):

    time.sleep(1)

    print('hello',os.getpid())

def Bar(*args):

    print('程序完成之后，主进程进行回调...',os.getpid())

if __name__ == '__main__':

    pool = Pool(5) # 创建进程池

    print(os.getpid())

    for i in range(10):

        # pool.apply(func=f, args=(i,))  # 串行执行

        pool.apply_async(func=f, args=(i,), callback=Bar)  

        # 并行执行 callback 为回调函数，指的是执行完func之后才会执行的方法函数

        # pool.apply_async(func=f, args=(i,))

    pool.close()

    pool.join()

    print('end')

参考：https://www.onexing.cn