Политики¶Policies

Получение и установка политики¶Getting and Setting the Policy

Следующие функции можно использовать для получения и установки политики для текущего процесса:

asyncio.get_event_loop_policy()¶

Возвращает текущую политику для всего процесса.

asyncio.set_event_loop_policy(policy)¶

Устанавливает текущую политику для всего процесса в policy.

Если для policy установлено значение None, восстанавливается стандартная политика.

Объекты политик¶Policy Objects

Абстрактный базовый класс политики цикла событий определяется следующим образом:

class asyncio.AbstractEventLoopPolicy¶

Абстрактный базовый класс для политик asyncio.

get_event_loop()¶

Возвращает цикл событий для текущего контекста.

Возвращает объект цикла событий, реализующий интерфейс AbstractEventLoop.

Этот метод никогда не должен возвращать None.

Изменено в версии 3.6.

set_event_loop(loop)¶

Устанавливает цикл событий для текущего контекста равным loop.

new_event_loop()¶

Создаёт и возвращает новый объект цикла событий.

Этот метод никогда не должен возвращать None.

get_child_watcher()¶

Получить объект наблюдателя за дочерними процессами.

Возвращает объект наблюдателя, реализующий AbstractChildWatcher интерфейс.

Эта функция специфична для Unix.

set_child_watcher(watcher)¶

Устанавливает текущий наблюдатель за дочерними процессами на watcher.

Эта функция специфична для Unix.

asyncio включает следующие встроенные политики:

class asyncio.DefaultEventLoopPolicy¶

Политика asyncio по умолчанию. Использует SelectorEventLoop как на Unix, так и на Windows.

Нет необходимости устанавливать политику по умолчанию вручную. asyncio настроена на автоматическое использование политики по умолчанию.

class asyncio.WindowsProactorEventLoopPolicy¶

Альтернативная политика цикла событий, использующая реализацию цикла событий ProactorEventLoop.

Доступность: Windows.

Наблюдатели за процессами¶Process Watchers

Наблюдатель за процессами позволяет настраивать, как цикл событий отслеживает дочерние процессы в Unix. В частности, циклу событий необходимо знать, когда дочерний процесс завершился.

В asyncio дочерние процессы создаются с помощью функций create_subprocess_exec() и loop.subprocess_exec().

asyncio определяет абстрактный базовый класс AbstractChildWatcher, который должны реализовывать наблюдатели за дочерними процессами, и имеет две различные реализации: SafeChildWatcher (настроена для использования по умолчанию) и FastChildWatcher.

См. также раздел Подпроцессы и потоки .

Следующие две функции можно использовать для настройки реализации наблюдателя за дочерними процессами, используемого циклом событий asyncio:

asyncio.get_child_watcher()¶

Возвращает текущий наблюдатель за дочерними процессами для текущей политики.

asyncio.set_child_watcher(watcher)¶

Устанавливает текущий наблюдатель за дочерними процессами на watcher для текущей политики. watcher должен реализовывать методы, определённые в базовом классе AbstractChildWatcher.

class asyncio.AbstractChildWatcher¶

add_child_handler(pid, callback, *args)¶

Регистрирует новый обработчик дочернего процесса.

Организует вызов callback(pid, returncode, *args) при завершении процесса с PID, равным pid. Указание другого колбэка для того же процесса заменяет предыдущий обработчик.

Вызываемый объект колбэк должен быть потокобезопасным.

remove_child_handler(pid)¶

Удаляет обработчик для процесса с PID, равным pid.

Функция возвращает True, если обработчик был успешно удалён, и False, если удалять было нечего.

attach_loop(loop)¶

Присоединяет наблюдатель к циклу событий.

Если наблюдатель ранее был присоединён к циклу событий, то перед присоединением к новому циклу он сначала отсоединяется.

Примечание: loop может быть None.

close()¶

Закрывает наблюдатель.

Этот метод необходимо вызвать, чтобы гарантировать очистку нижележащих ресурсов.

class asyncio.SafeChildWatcher¶

Эта реализация предотвращает нарушение работы другого кода, порождающего процессы, за счет явного опроса каждого процесса по сигналу SIGCHLD.

Это безопасное решение, но оно создает значительные накладные расходы при обработке большого количества процессов (O(n) каждый раз при получении SIGCHLD).

asyncio использует эту безопасную реализацию по умолчанию.

class asyncio.FastChildWatcher¶

Эта реализация собирает каждый завершённый процесс, напрямую вызывая os.waitpid(-1), что потенциально нарушает работу другого кода, запускающего процессы и ожидающего их завершения.

Нет заметных накладных расходов при обработке большого количества дочерних процессов (O(1) каждый раз при завершении дочернего процесса).

Пользовательские политики¶Custom Policies

Для реализации новой политики цикла событий рекомендуется создать подкласс DefaultEventLoopPolicy и переопределить методы, для которых требуется особое поведение, например:

class MyEventLoopPolicy(asyncio.DefaultEventLoopPolicy):

    def get_event_loop(self):
        """Получить цикл событий.

        Это может быть None или экземпляр EventLoop.
        """
        loop = super().get_event_loop()
        # Сделать что-то с циклом ...
        return loop

asyncio.set_event_loop_policy(MyEventLoopPolicy())