Skip to content

Latest commit

 

History

History
162 lines (106 loc) · 5.49 KB

File metadata and controls

162 lines (106 loc) · 5.49 KB
.. currentmodule:: asyncio


Runners

Source code: :source:`Lib/asyncio/runners.py`

This section outlines high-level asyncio primitives to run asyncio code.

They are built on top of an :ref:`event loop <asyncio-event-loop>` with the aim to simplify async code usage for common wide-spread scenarios.

.. function:: run(coro, *, debug=None, loop_factory=None)

   Execute the :term:`coroutine` *coro* and return the result.

   This function runs the passed coroutine, taking care of
   managing the asyncio event loop, *finalizing asynchronous
   generators*, and closing the executor.

   This function cannot be called when another asyncio event loop is
   running in the same thread.

   If *debug* is ``True``, the event loop will be run in debug mode. ``False`` disables
   debug mode explicitly. ``None`` is used to respect the global
   :ref:`asyncio-debug-mode` settings.

   If *loop_factory* is not ``None``, it is used to create a new event loop;
   otherwise :func:`asyncio.new_event_loop` is used. The loop is closed at the end.
   This function should be used as a main entry point for asyncio programs,
   and should ideally only be called once. It is recommended to use
   *loop_factory* to configure the event loop instead of policies.
   Passing :class:`asyncio.EventLoop` allows running asyncio without the
   policy system.

   The executor is given a timeout duration of 5 minutes to shutdown.
   If the executor hasn't finished within that duration, a warning is
   emitted and the executor is closed.

   Example::

       async def main():
           await asyncio.sleep(1)
           print('hello')

       asyncio.run(main())

   .. versionadded:: 3.7

   .. versionchanged:: 3.9
      Updated to use :meth:`loop.shutdown_default_executor`.

   .. versionchanged:: 3.10

      *debug* is ``None`` by default to respect the global debug mode settings.

   .. versionchanged:: 3.12

      Added *loop_factory* parameter.


A context manager that simplifies multiple async function calls in the same context.

Sometimes several top-level async functions should be called in the same :ref:`event loop <asyncio-event-loop>` and :class:`contextvars.Context`.

If debug is True, the event loop will be run in debug mode. False disables debug mode explicitly. None is used to respect the global :ref:`asyncio-debug-mode` settings.

loop_factory could be used for overriding the loop creation. It is the responsibility of the loop_factory to set the created loop as the current one. By default :func:`asyncio.new_event_loop` is used and set as current event loop with :func:`asyncio.set_event_loop` if loop_factory is None.

Basically, :func:`asyncio.run()` example can be rewritten with the runner usage:

async def main():
    await asyncio.sleep(1)
    print('hello')

with asyncio.Runner() as runner:
    runner.run(main())
.. versionadded:: 3.11

.. method:: run(coro, *, context=None)

   Run a :term:`coroutine <coroutine>` *coro* in the embedded loop.

   Return the coroutine's result or raise its exception.

   An optional keyword-only *context* argument allows specifying a
   custom :class:`contextvars.Context` for the *coro* to run in.
   The runner's default context is used if ``None``.

   This function cannot be called when another asyncio event loop is
   running in the same thread.

.. method:: close()

   Close the runner.

   Finalize asynchronous generators, shutdown default executor, close the event loop
   and release embedded :class:`contextvars.Context`.

.. method:: get_loop()

   Return the event loop associated with the runner instance.

Note

:class:`Runner` uses the lazy initialization strategy, its constructor doesn't initialize underlying low-level structures.

Embedded loop and context are created at the :keyword:`with` body entering or the first call of :meth:`run` or :meth:`get_loop`.

.. versionadded:: 3.11

When :const:`signal.SIGINT` is raised by Ctrl-C, :exc:`KeyboardInterrupt` exception is raised in the main thread by default. However this doesn't work with :mod:`asyncio` because it can interrupt asyncio internals and can hang the program from exiting.

To mitigate this issue, :mod:`asyncio` handles :const:`signal.SIGINT` as follows:

  1. :meth:`asyncio.Runner.run` installs a custom :const:`signal.SIGINT` handler before any user code is executed and removes it when exiting from the function.
  2. The :class:`~asyncio.Runner` creates the main task for the passed coroutine for its execution.
  3. When :const:`signal.SIGINT` is raised by Ctrl-C, the custom signal handler cancels the main task by calling :meth:`asyncio.Task.cancel` which raises :exc:`asyncio.CancelledError` inside the main task. This causes the Python stack to unwind, try/except and try/finally blocks can be used for resource cleanup. After the main task is cancelled, :meth:`asyncio.Runner.run` raises :exc:`KeyboardInterrupt`.
  4. A user could write a tight loop which cannot be interrupted by :meth:`asyncio.Task.cancel`, in which case the second following Ctrl-C immediately raises the :exc:`KeyboardInterrupt` without cancelling the main task.