Документация

Узнайте, как использовать TrueAsync для создания конкурентных PHP-приложений.

Channel::recv

(PHP 8.6+, True Async 1.0)

public Channel::recv(?Completable $cancellationToken = null): mixed

Получает следующее значение из канала. Операция является блокирующей — текущая корутина приостанавливается, если в канале нет доступных значений.

Если канал закрыт и буфер пуст, выбрасывается ChannelException. Если канал закрыт, но в буфере остались значения, они будут возвращены.

Параметры

cancellationToken
Токен отмены (Completable), позволяющий прервать ожидание по произвольному условию. null — ожидание без ограничений (по умолчанию). Когда токен завершается, операция прерывается и выбрасывается CancelledException. Для ограничения по времени можно использовать Async\timeout().

Возвращаемые значения

Следующее значение из канала (mixed).

Ошибки

Примеры

Пример #1 Получение значений из канала

<?php

use Async\Channel;

$channel = new Channel(5);

spawn(function() use ($channel) {
    for ($i = 1; $i <= 5; $i++) {
        $channel->send($i);
    }
    $channel->close();
});

spawn(function() use ($channel) {
    try {
        while (true) {
            $value = $channel->recv();
            echo "Получено: $value\n";
        }
    } catch (\Async\ChannelException) {
        echo "Канал закрыт и пуст\n";
    }
});

Пример #2 Получение с таймаутом

<?php

use Async\Channel;

$channel = new Channel();

spawn(function() use ($channel) {
    try {
        $value = $channel->recv(Async\timeout(2000));
        echo "Получено: $value\n";
    } catch (\Async\CancelledException) {
        echo "Данные не поступили за 2 секунды\n";
    }
});

Пример #3 Получение с произвольным токеном отмены

<?php

use Async\Channel;
use Async\Future;

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

spawn(function() use ($channel, $cancel) {
    try {
        $value = $channel->recv($cancel);
        echo "Получено: $value\n";
    } catch (\Async\CancelledException) {
        echo "Получение отменено\n";
    }
});

// Отменяем из другой корутины
spawn(function() use ($cancel) {
    Async\delay(500);
    $cancel->complete(null);
});

См. также