python

import asyncio,time,random  
from concurrent.futures import ThreadPoolExecutor  
import socket  
from urllib.parse import urlparse  
  
def func(a):  
    # 阻塞方法  
    t=random.randint(0,5)  
    print("arg is %s"%a)  
    print("start sleep %s"%t)  
    time.sleep(t)  
    print("end sleep %s"%t)  
  
if __name__ == "__main__":  
    start_time = time.time()  
  
    loop = asyncio.get_event_loop()  
    executor = ThreadPoolExecutor(3) # 申请线程池  
    tasks = []  
    for i in range(0,20):  
        task = loop.run_in_executor(executor, func, i)  
        # 注意协程的这个函数，传入的是executor，返回是封装的Future对象，可以直接放在协程中使用  
        tasks.append(task)  
    loop.run_until_complete(asyncio.wait(tasks))  
  
    print("last time:{}".format(time.time()-start_time))

arg is 0
start sleep 4
arg is 1
start sleep 4
arg is 2
start sleep 3
end sleep 3
arg is 19
start sleep 3
end sleep 4
end sleep 4
...