Python3.7的新API:asyncio.run()

Python3.7的新API:asyncio.run() Python3.7的正式版本已经发布有一段时间了，出了内置的breakpoint()断点函数，颇受争议的dataclass,自定义模块里的__getattr__()和__dir__()魔法方法等新特性外以及一些底层的改进外，还添加了一些新的api。其中我个人比较喜欢的一个新API是asyncio.run()方法，可以省去显式的定义事件循环的步骤。 传统的asyncio异步事件循环 在Python3.7以前的版本，调用异步函数前要先调用asyncio.get_event_loop()函数获取事件循环loop对象，然后通过不同的策略调用lo Python3.7引入了一个重要的新API，即`asyncio.run()`，这极大地简化了异步编程的使用方式。在之前的版本中，为了执行异步任务，开发者需要手动创建并管理事件循环（Event Loop）。`asyncio.run()`的出现使得这个过程变得更加直观和简洁。 在Python的异步编程中，`asyncio`库是核心组件，它提供了基于协程（Coroutines）的异步I/O支持。在Python3.6及更早版本中，执行异步任务通常涉及以下步骤： 1. 获取事件循环：通过`asyncio.get_event_loop()`获取当前线程的事件循环对象。 2. 创建任务：将异步函数转换为可调度的任务，通常使用`asyncio.create_task()`或`asyncio.ensure_future()`。 3. 运行事件循环：使用`loop.run_forever()`或`loop.run_until_complete()`启动并运行事件循环，直到所有任务完成。 例如，下面是一个传统的异步任务执行示例： ```python import asyncio import random import datetime async def wait_and_echo(content): wait = random.randint(0, 10) print(f'print {content} after {wait} seconds') await asyncio.sleep(wait) print(f'{content} printed at {datetime.datetime.utcnow().strftime("%H:%M:%S ")}') async def main(): await asyncio.gather(*[wait_and_echo(x) for x in range(10)]) loop = asyncio.get_event_loop() tasks = [wait_and_echo(x) for x in range(10)] loop.run_until_complete(asyncio.gather(*tasks)) ``` 在Python3.7中，`asyncio.run()`函数的引入简化了这个流程。它自动创建一个新的事件循环，调度并执行给定的协程，然后在任务完成后关闭事件循环。以下是使用`asyncio.run()`的相同示例： ```python async def main(): await asyncio.gather(*[wait_and_echo(x) for x in range(10)]) asyncio.run(main()) ``` `asyncio.run()`的使用更加直观，无需显式地管理和关闭事件循环。然而，需要注意的是，`asyncio.run()`不能在已经运行的事件循环中被调用，且它设计为程序的主入口点，理想情况下只应被调用一次。此外，如果`debug`参数设置为`True`，它会以调试模式运行事件循环，提供额外的错误检查和诊断信息。 `asyncio.run()`是Python3.7中的一大亮点，它降低了异步编程的门槛，使得编写和理解异步代码变得更加容易。这个新API的引入鼓励开发者更加高效地利用异步机制，特别是在处理I/O密集型任务时，能够显著提高程序的并发性能。