线程池

from concurrent.futures import ThreadPoolExecutor

def worker(x):
   return x * x

with ThreadPoolExecutor(max_workers=4) as executor:
   results = list(executor.map(worker, range(10)))

进程池

from concurrent.futures import ProcessPoolExecutor

with ProcessPoolExecutor() as executor:
   results = list(executor.map(worker, range(10)))

转载请注明：周志洋的博客 » Python实用技巧-并发编程进阶