首页 > 技术文章 > 线程池和进程池的通用写法 ProcessPoolExecutor 和 ThreadPoolExecutor

16795079a 2019-01-14 20:20 原文

import time

from comcurrent.futures import ThreadPoolExecutor,ProcessPoolExccoutor#这个方法可以用进程池或者线程池

def f1(i):

  print(i)

  time.sleep(2)

if __name__ == '__main__':

  tp = ThreadPoolExecutor(4)#指定线程池的大小          #如果改成进程池则是ProcessPoolExecutor

  lst = []

  for i in range(10):

    res = rp.submit(f1,i)#sunmit 翻译:异步    作用是给多线程或进程异步提交任务

    lst.append(res)

   tp.shutdown()主线程等待所有提交给线程池的任务,全部执行完毕  close+join

         for  i  in lst:

      print(i.result())#拿到结果   request  翻译:   结果

   print('主程序运行结束')

  

推荐阅读