【Python】进程池的使用

import os
import time
from multiprocessing import Pool


def worker(msg):
    print('%s开始执行，进程号为%d' % (msg, os.getpid()))
    time.sleep(2)


if __name__ == '__main__':

    po = Pool(3)  # 定义一个进程池，最大进程数3

    for i in range(20):
        # pool.apply_async（调用的目标，（元组传参数））
        # 每次循环都会将会用空闲出来的子进程调用目标
        po.apply_async(worker, (i,))

    po.close()  # 关闭进程池
    po.join()  # 等待子进程执行完成
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容