Python 3.5 增加了对async def
and await
的支持,同样的异步代码看起来干净了很多,也更易读。
import aiohttpimport asyncioasync def get_status(url, id): r = await aiohttp.get(url) print(r.status, id) r.close()tasks = []for i in range(100): tasks.append(asyncio.ensure_future(get_status('https://api.github.com/events', id=i)))if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(asyncio.wait(tasks)) loop.close()
原文链接: