python3.5+ asyncio await異步詳解
阿新 • • 發佈:2019-01-11
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異步詳解