文档

了解如何使用 TrueAsync 构建并发 PHP 应用程序。

Channel::recvAsync

(PHP 8.6+, True Async 1.0)

public Channel::recvAsync(): Future

对通道执行非阻塞接收操作，并返回一个 Future 对象， 可以在之后进行等待。

与 recv() 不同，此方法不会立即挂起当前协程。 而是返回一个 Future，当值可用时将被解析。

返回值

一个 Future 对象，将解析为从通道接收到的值。

示例

示例 #1 非阻塞接收

<?php

use Async\Channel;

$channel = new Channel(3);

spawn(function() use ($channel) {
    $channel->send('data A');
    $channel->send('data B');
    $channel->close();
});

spawn(function() use ($channel) {
    $futureA = $channel->recvAsync();
    $futureB = $channel->recvAsync();

    // 可以在尚不需要数据时执行其他工作
    doSomeWork();

    echo await($futureA) . "\n"; // "data A"
    echo await($futureB) . "\n"; // "data B"
});

示例 #2 从多个通道并行接收

<?php

use Async\Channel;

$orders = new Channel(10);
$notifications = new Channel(10);

spawn(function() use ($orders, $notifications) {
    $orderFuture = $orders->recvAsync();
    $notifFuture = $notifications->recvAsync();

    // 等待任一通道中第一个可用的值
    [$result, $index] = awaitAnyOf($orderFuture, $notifFuture);

    echo "Received from channel #$index: $result\n";
});

参见