池:表示容器。线程池就是存放线程的容器,进程池就是存放进程的容器
# 进程池
from concurrent.futures import ProcessPoolExecutor
from multiprocessing import Process
import os
import time
def task():
time.sleep(0.1)
print(os.getpid())
if __name__ == '__main__':
pool = ProcessPoolExecutor(3)
# 提交任务到池子中
pool.submit(task)
# time.sleep(1)
pool.submit(task)
147332
147320
# 线程池
from concurrent.futures import ThreadPoolExecutor
from threading import active_count,enumerate,currentThread
import os
import time
def task():
print(currentThread().name)
# 创建线程池
pool = ThreadPoolExecutor(3)
# 提交任务到池子中
pool.submit(task)
pool.submit(task)
print(f"{enumerate()}")
print(f"{active_count()}")
ThreadPoolExecutor-0_0
ThreadPoolExecutor-0_0
[<_MainThread(MainThread, started 135020)>, <Thread(ThreadPoolExecutor-0_0, started daemon 134904)>, <Thread(ThreadPoolExecutor-0_1, started daemon 134872)>]
3
如果主进程不结束,池子里面的进程或线程,也是一直存活的
原文:https://www.cnblogs.com/plf-Jack/p/11139895.html