首页 > 编程语言 > 详细

线程池和进程池的通用写法 ProcessPoolExecutor 和 ThreadPoolExecutor

时间:2019-01-14 20:58:37      阅读:214      评论:0      收藏:0      [点我收藏+]

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(‘主程序运行结束‘)

  

线程池和进程池的通用写法 ProcessPoolExecutor 和 ThreadPoolExecutor

原文:https://www.cnblogs.com/16795079a/p/10268847.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!