Channel::send

(PHP 8.6+, True Async 1.0)

public Channel::send(mixed $value, ?Completable $cancellationToken = null): void

Sendet einen Wert an den Channel. Dies ist eine blockierende Operation — die aktuelle Coroutine wird suspendiert, wenn der Channel den Wert nicht sofort annehmen kann.

Bei einem Rendezvous-Channel (capacity = 0) wartet der Sender, bis eine andere Coroutine recv() aufruft. Bei einem gepufferten Channel wartet der Sender nur, wenn der Puffer voll ist.

Parameter

value: Der zu sendende Wert. Kann von beliebigem Typ sein.
cancellationToken: Abbruch-Token (Completable), das den Abbruch des Wartens nach beliebigen Bedingungen ermöglicht. null — unbegrenzt warten (Standard). Wenn das Token abgeschlossen wird, wird die Operation abgebrochen und eine CancelledException ausgelöst. Für zeitbasierte Begrenzungen kann Async\timeout() verwendet werden.

Fehler

Löst Async\ChannelException aus, wenn der Channel geschlossen ist.
Löst Async\CancelledException aus, wenn das Abbruch-Token abgeschlossen wurde.

Beispiele

Beispiel #1 Werte an einen Channel senden

<?php

use Async\Channel;

$channel = new Channel(1);

spawn(function() use ($channel) {
    $channel->send('first');  // Im Puffer abgelegt
    $channel->send('second'); // Wartet, bis Platz frei wird
    $channel->close();
});

spawn(function() use ($channel) {
    echo $channel->recv() . "\n"; // "first"
    echo $channel->recv() . "\n"; // "second"
});

Beispiel #2 Senden mit Timeout

<?php

use Async\Channel;

$channel = new Channel(0); // Rendezvous

spawn(function() use ($channel) {
    try {
        $channel->send('data', Async\timeout(1000));
    } catch (\Async\CancelledException $e) {
        echo "Timeout: Niemand hat den Wert innerhalb von 1 Sekunde angenommen\n";
    }
});

Beispiel #3 Senden mit benutzerdefiniertem Abbruch-Token

<?php

use Async\Channel;
use Async\Future;

$channel = new Channel(0);
$cancel = new Future();

spawn(function() use ($channel, $cancel) {
    try {
        $channel->send('data', $cancel);
    } catch (\Async\CancelledException $e) {
        echo "Senden abgebrochen\n";
    }
});

// Operation aus einer anderen Coroutine abbrechen
spawn(function() use ($cancel) {
    Async\delay(500);
    $cancel->complete(null);
});

Siehe auch

Channel::sendAsync — Nicht-blockierendes Senden
Channel::recv — Einen Wert vom Channel empfangen
Channel::isFull — Prüfen, ob der Puffer voll ist
Channel::close — Den Channel schließen

Seite bearbeiten

Dokumentation