python 阻塞模式 进程池

"""
阻塞模式：一个一个任务单独放进进程池，处理完一个再放下一个任务进来，主进程要等着些执行完再执行
"""

import os
import time
from multiprocessing import Pool
from random import random


def task(name):
    print("进行任务{}  进程ID:{}".format(name, os.getpid()))
    start = time.time()
    # random() 的值是0到1之间，这里就表示休眠 0到2秒
    time.sleep(random() * 2)
    end = time.time()
    print("完成任务:{}  用时:{}  进程ID:{}".format(name, (end - start), os.getpid()))


if __name__ == '__main__':
    pool = Pool(5)  # 创建一个进程池，里面放5个进程
    tasks = ["任务1", "任务2", "任务3", "任务4", "任务5", "任务6", "任务7"]
    for t in tasks:
        # apply 阻塞模式,一个一个任务单独放进进程池，进程池中的进程被轮流使用
        pool.apply(task, args=(t,))

    pool.close()  # 当进程池close的时候并未关闭进程池，只是会把状态改为不可再插入元素的状态，完全关闭进程池使用
    # pool.join()  # 阻塞模式的只有当它里面的任务全部都执行完，才继续，所以不需要这步


    print("over")