Канал协程通道

Канал - это механизм связи между корутинами. Одна корутина может отправлять данные в канал, а другая может извлекать данные из него, что позволяет обеспечить синхронизацию и совместное использование данных между корутинами.

提示
Эта функция требует workerman>=5.1.0

Внимание

• На нижнем уровне автоматически поддерживаются Swoole/Swow/Fiber/Select/Event-управляемые
• При использовании Select/Event-управляемых не поддерживаются параметры таймаута для pop/push

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Channel;
use Workerman\Coroutine;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// Http Server
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // Или Swow::class или Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $channel = new Channel(2);
    Coroutine::create(function () use ($channel) {
        $channel->push('Задача 1 завершена');
    });
    Coroutine::create(function () use ($channel) {
        $channel->push('Задача 2 завершена');
    });
    $result = [];
    for ($i = 0; $i < 2; $i++) {
        $result[] = $channel->pop();
    }
    $connection->send(json_encode($result)); // Ответ: ["Задача 1 завершена","Задача 2 завершена"]
};
Worker::runAll();

Описание интерфейса

interface ChannelInterface
{
    /**
     * Отправляет данные в канал, поддерживает таймаут (в секундах), при истечении времени возвращает false
     */
    public function push(mixed $data, float $timeout = -1): bool;

    /**
     * Извлекает данные из канала, поддерживает таймаут (таймаут в секундах), при истечении времени возвращает false
     */
    public function pop(float $timeout = -1): mixed;

    /**
     * Получает длину данных в канале
     */
    public function length(): int;

    /**
     * Получает ёмкость канала
     */
    public function getCapacity(): int;

    /**
     * Есть ли потребители, то есть есть ли корутины, ожидающие pop данных
     */
    public function hasConsumers(): bool;

    /**
     * Есть ли производители, то есть есть ли корутины, ожидающие push данных в канал
     */
    public function hasProducers(): bool;

    /**
     * Закрывает канал
     */
    public function close(): void;

}