signal

(PHP 8.6+, True Async 1.0)

signal() — Attende un segnale del sistema operativo. Restituisce un Future che si risolve con un valore Signal quando il segnale viene ricevuto.

Descrizione

signal(Async\Signal $signal, ?Async\Completable $cancellation = null): Async\Future

Crea un gestore di segnali del sistema operativo a uso singolo. Ogni chiamata a signal() crea un nuovo Future che si risolve alla prima ricezione del segnale specificato. Se viene fornito il parametro $cancellation, il Future verrà rifiutato quando l’annullamento si attiva (es. al timeout).

Chiamate multiple a signal() con lo stesso segnale funzionano in modo indipendente — ognuna riceverà una notifica.

Parametri

signal Un valore dell’enum Async\Signal che specifica il segnale atteso. Ad esempio: Signal::SIGINT, Signal::SIGTERM, Signal::SIGUSR1.

cancellation Un oggetto opzionale che implementa Async\Completable (es. il risultato di una chiamata a timeout()). Se l’oggetto di annullamento si attiva prima dell’arrivo del segnale, il Future verrà rifiutato con l’eccezione corrispondente (es. Async\TimeoutException).

Se l’oggetto di annullamento è già completato al momento della chiamata, signal() restituisce immediatamente un Future rifiutato.

Valori di ritorno

Restituisce Async\Future<Async\Signal>. Quando il segnale viene ricevuto, il Future si risolve con il valore dell’enum Async\Signal corrispondente al segnale ricevuto.

Errori/Eccezioni

• Async\OperationCanceledException — se il token di cancellazione si è attivato (incluso il timeout). L’eccezione originale del token è disponibile tramite $e->getPrevious() (ad esempio, TimeoutException quando si usa timeout()).

Esempi

Esempio #1 Attesa di un segnale con timeout

<?php
use Async\Signal;
use function Async\signal;
use function Async\timeout;
use function Async\await;

try {
    $result = await(signal(Signal::SIGINT, timeout(5000)));
    echo "Segnale ricevuto: " . $result->name . "\n";
} catch (Async\OperationCanceledException $e) {
    echo "Segnale non ricevuto entro 5 secondi\n";
}
?>

Esempio #2 Ricezione di un segnale da un’altra coroutine

<?php
use Async\Signal;
use function Async\signal;
use function Async\await;
use function Async\spawn;

$future = signal(Signal::SIGUSR1);

spawn(function() {
    posix_kill(getmypid(), SIGUSR1);
});

$result = await($future);
echo "Segnale ricevuto: " . $result->name . "\n";
var_dump($result === Signal::SIGUSR1); // bool(true)
?>

Esempio #3 Arresto controllato su SIGTERM

<?php
use Async\Signal;
use function Async\signal;
use function Async\await;
use function Async\spawn;
use function Async\graceful_shutdown;

spawn(function() {
    await(signal(Signal::SIGTERM));
    echo "SIGTERM ricevuto, arresto in corso...\n";
    graceful_shutdown();
});
?>

Esempio #4 Timeout già scaduto

<?php
use Async\Signal;
use function Async\signal;
use function Async\timeout;
use function Async\await;
use function Async\delay;

$t = timeout(1);
delay(50); // Il timeout è già scaduto

$future = signal(Signal::SIGINT, $t);

try {
    await($future);
} catch (Async\OperationCanceledException $e) {
    echo get_class($e) . "\n"; // Async\OperationCanceledException
    echo get_class($e->getPrevious()) . "\n"; // Async\TimeoutException
}
?>

Note

Nota: Ogni chiamata a signal() crea un gestore a uso singolo. Per attendere lo stesso segnale di nuovo, chiamare nuovamente signal().

Nota: Signal::SIGINT e Signal::SIGBREAK funzionano su tutte le piattaforme, incluso Windows. I segnali SIGUSR1, SIGUSR2 e altri segnali POSIX sono disponibili solo su sistemi Unix.

Nota: Signal::SIGKILL e Signal::SIGSEGV non possono essere catturati — questa è una limitazione del sistema operativo.

Signal

L’enum Async\Signal definisce i segnali del sistema operativo disponibili:

Vedi anche

• timeout() — creare un timeout per limitare l’attesa
• await() — attesa del risultato di un Future
• graceful_shutdown() — arresto controllato dello scheduler
• Cancellazione — meccanismo di annullamento