python多进程并行计算

下面是一个例子

from multiprocessing import Pool
import time

def func(i):
    time.sleep(1)
    print("正在执行进程", i)

if __name__ == '__main__':

    p = Pool(5)     # 创建一个包含5个进程的进程池

    for i in range(30):
        p.apply_async(func=func, args=(i,))

    p.close()           # 等子进程执行完毕后关闭进程池
    # time.sleep(2)
    # p.terminate()     # 立刻关闭进程池
    p.join()