Canal de Co-rotinas

O Canal é um mecanismo de comunicação entre co-rotinas. Uma co-rotina pode empurrar dados para o canal, enquanto outra co-rotina pode retirar dados dele, permitindo assim a sincronização e o compartilhamento de dados entre co-rotinas.

Dica
Esse recurso requer workerman>=5.1.0

Atenção

• A implementação subjacente suporta automaticamente Swoole/Swow/Fiber/Select/Event
• Ao usar o modelo de eventos Select/Event, os parâmetros de tempo limite para pop/push não são suportados

<?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';

// Servidor Http
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // Ou Swow::class ou Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $channel = new Channel(2);
    Coroutine::create(function () use ($channel) {
        $channel->push('Tarefa 1 Concluída');
    });
    Coroutine::create(function () use ($channel) {
        $channel->push('Tarefa 2 Concluída');
    });
    $result = [];
    for ($i = 0; $i < 2; $i++) {
        $result[] = $channel->pop();
    }
    $connection->send(json_encode($result)); // Resposta: ["Tarefa 1 Concluída","Tarefa 2 Concluída"]
};
Worker::runAll();

Descrição da Interface

interface ChannelInterface
{
    /**
     * Empurra dados para o canal, suporta tempo limite (em segundos), retorna false em caso de tempo limite
     */
    public function push(mixed $data, float $timeout = -1): bool;

    /**
     * Retira dados do canal, suporta tempo limite (tempo limite em segundos), retorna false em caso de tempo limite
     */
    public function pop(float $timeout = -1): mixed;

    /**
     * Obtém o comprimento dos dados no canal
     */
    public function length(): int;

    /**
     * Obtém a capacidade do canal
     */
    public function getCapacity(): int;

    /**
     * Verifica se há consumidores, ou seja, se há co-rotinas aguardando pop dos dados
     */
    public function hasConsumers(): bool;

    /**
     * Verifica se há produtores, ou seja, se há co-rotinas aguardando push de dados para o canal
     */
    public function hasProducers(): bool;

    /**
     * Fecha o canal
     */
    public function close(): void;

}