###################### 线程池 ############
from concurrent.futures import ThreadPoolExecutor
import time
def task(arg):
print(arg)
time.sleep(1)
pool = ThreadPoolExecutor(5)
for i in range(50):
pool.submit(task,i)
#################################################
############################# 进程池 #################
from concurrent.futures import ProcessPoolExecutor
import time
def task(arg):
print(arg)
time.sleep(1)
if __name__ == '__main__':
pool = ProcessPoolExecutor(3)
for i in range(50):
pool.submit(task,i)
