进程池

import time
from concurrent.futures import ProcessPoolExecutor def task(arg):
time.sleep(2)
print(arg) if __name__ == '__main__':
pool = ProcessPoolExecutor(5)
for i in range(20):
pool.submit(task, i)

线程池

import time
from concurrent.futures import ThreadPoolExecutor def task(arg):
time.sleep(2)
print(arg) if __name__ == '__main__':
pool = ThreadPoolExecutor(5)
for i in range(20):
pool.submit(task, i)
05-17 23:29