进程池

Posted 2020-12-25 wy3713

进程是不能无限开启的

如果必须要用多个进行

　　而且是高计算型 没有IO操作的程序

　　希望并行最充分的使用cpu

import os
import time
from multiprocessing import Pool
def func(i):
    time.sleep(0.1)
    print(os.getpid(),i)

if __name__ == ‘__main__‘:
    p = Pool(5)
    for i in range(20):
        p.apply_async(func,args=(i,))
    p.close()
    p.join()