python 多线程(多个线程一起返回结果)

时间:2020-07-21 22:25:47   收藏:0   阅读:164

待整理:

测试代码:

‘‘‘
Created on 2020年7月21日

@author: sea
‘‘‘
from concurrent.futures.thread import ThreadPoolExecutor
from concurrent.futures._base import as_completed
from time import sleep


def send_request(req_url,json):
#     print(req_url+ "     "+json)
    sleep(3)
    return req_url
    
    
    
if __name__ == __main__:
    executor = ThreadPoolExecutor(max_workers=3)
    all_task=[]
    for i in range(10):
        pass
        task = executor.submit(send_request,"url--"+ str(i),str(i)+"json")
        all_task.append(task)
        print("all_task size is "+str(len(all_task)))
    for future in as_completed(all_task):
        pass
        result = future.result()
        print(result)

 

原文:https://www.cnblogs.com/lshan/p/13356788.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!