1. 程式人生 > >python3.5+ asyncio await異步詳解

python3.5+ asyncio await異步詳解

asyncio tasks default eal 分享 lis cond task python3.5

import asyncio,time
from collections import defaultdict
from pprint import pprint

collect=defaultdict(list)

#######創建處理一個對象的方法,並返回期物
async def dealone(chunk):
	return ‘Receive %d at %.5f seconds‘ % (chunk,time.time())

#######委派給dealone處理,並獲取處理結果
async def submitor(chunk):
	future=await dealone(chunk)
	collect[‘res‘].append(future)

chunks=range(10)

loop = asyncio.get_event_loop()
tasks=asyncio.wait([submitor(chunk) for chunk in chunks])
loop.run_until_complete(tasks)
pprint(collect[‘res‘])

 技術分享圖片

python3.5+ asyncio await異步詳解