KomponentenChannel::send

Channel::send ​

(PHP 8.6+, True Async 1.0)

php
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 AsyncCancellation 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\AsyncCancellation aus, wenn das Abbruch-Token abgeschlossen wurde.

Beispiele ​

Beispiel #1 Werte an einen Channel senden ​

php
<?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
<?php

use Async\Channel;

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

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

Beispiel #3 Senden mit benutzerdefiniertem Abbruch-Token ​

php
<?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\AsyncCancellation $e) {
        echo "Senden abgebrochen\n";
    }
});

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

Siehe auch ​