day32-2 线程池与进程池

线程池和进程池

线程池是装线程的池子，进程池是装进程的池子。

1.可以避免频繁的创建和销毁线程(进程)带来的资源开销

2.可以限制同时存在的线程数量，以保证服务器不会因为资源不而导致崩溃

3.可以帮我们管理线程的生命周期

4.管理任务的分配

线程池的使用

import time
from concurrent.futures import ThreadPoolExecutor
from threading import currentThread


def task():
    time.sleep(2)
    print(currentThread().name)  # 打印线程名


pool = ThreadPoolExecutor(5)  # 创建线程池，指定最多可以容纳5个线程
for i in range(10):
    pool.submit(task)  # 提交任务到池子中


print('start...')
pool.submit(task)  # 线程池中的线程执行完后会一直存活
pool.shutdown()  # 存活直到强制关闭线程池
pool.submit(task)  # 关闭后再次提交会报错 

进程池的使用

import os
import time
from concurrent.futures import ProcessPoolExecutor


def task():
    time.sleep(2)
    print("current pid:", os.getpid())


if __name__ == '__main__':
    pool = ProcessPoolExecutor(3)  # 创建进程池，指定最大可以容纳3个进程
    for i in range(10):
        pool.submit(task)  # 提交任务到进程池中

    pool.shutdown()  # 存活直到强制关闭进程池
    pool.submit(task)  # 关闭后再次提交会报错 

submit(task,参数) # 要给task传参数时，不用写args，直接写参数就好