Структура Signal

Обработчик для получения сигналов ОС определённого типа.

Обработчик можно преобразовать в Stream с помощью SignalStream.

В целом обработка сигналов в Unix — довольно сложная тема, и эта структура не исключение! При использовании потоков Signal следует помнить о некоторых важных ограничениях:

• Обработка сигналов в Unix уже требует в некоторых случаях объединения сигналов. Поток Signal здесь тоже не исключение: он также объединяет сигналы. То есть даже если обработчик сигнала для этого процесса запустится несколько раз, поток Signal может вернуть только одно уведомление о сигнале. В частности, до вызова poll все уведомления о сигналах объединяются в один элемент, возвращаемый из poll. Однако после вызова poll следующий сигнал гарантированно будет выдан как элемент.

  Иными словами, каждый элемент, полученный из возвращённого обработчика, соответствует как минимум одному сигналу, но, возможно, и нескольким.

• Обработка сигналов в целом относительно неэффективна. Хотя в этом crate возможны некоторые улучшения, не рекомендуется рассчитывать на одновременное открытие миллионов каналов сигналов.

Если у вас есть вопросы по этому поводу, можете создать issue в репозитории! Мы всегда рады новым подходам, позволяющим устранить некоторые из этих ограничений!

Предостережения

При первой регистрации экземпляра Signal для определённого типа сигнала устанавливается обработчик сигнала ОС, который заменяет стандартное поведение платформы при получении этого сигнала на всё время работы процесса.

Например, по умолчанию системы Unix завершают процесс при получении SIGINT. Но когда создаётся экземпляр Signal для прослушивания этого сигнала, следующий полученный SIGINT будет преобразован в событие потока, и выполнение процесса продолжится. Даже если этот экземпляр Signal будет удалён, последующие доставки SIGINT будут перехвачены Tokio, а стандартное поведение платформы НЕ будет восстановлено.

Поэтому приложениям следует позаботиться о том, чтобы после прослушивания определённых сигналов ожидаемое поведение сигналов сохранялось.

Примеры

Ожидание SIGHUP

use tokio::signal::unix::{signal, SignalKind};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // An infinite stream of hangup signals.
    let mut sig = signal(SignalKind::hangup())?;

    // Print whenever a HUP signal is received
    loop {
        sig.recv().await;
        println!("got signal HUP");
    }
}