Channel Canale delle Coroutine

Il Channel è un meccanismo di comunicazione tra coroutine. Una coroutine può inviare dati nel canale, mentre un'altra coroutine può estrarre dati da esso, realizzando così sincronizzazione e condivisione dei dati tra le coroutine.

Suggerimento
Questa funzionalità richiede workerman>=5.1.0

Attenzione

• Supporto automatico del livello sottostante per Swoole/Swow/Fiber/Select/Event
• Quando si utilizza il driver Select/Event, i parametri di timeout per pop/push non sono supportati

<?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; // Oppure Swow::class o Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $channel = new Channel(2);
    Coroutine::create(function () use ($channel) {
        $channel->push('Task 1 Done');
    });
    Coroutine::create(function () use ($channel) {
        $channel->push('Task 2 Done');
    });
    $result = [];
    for ($i = 0; $i < 2; $i++) {
        $result[] = $channel->pop();
    }
    $connection->send(json_encode($result)); // Risposta: ["Task 1 Done","Task 2 Done"]
};
Worker::runAll();

Descrizione dell'Interfaccia

interface ChannelInterface
{
    /**
     * Inviare dati al canale, supporta il timeout (unità in secondi), restituisce false in caso di timeout
     */
    public function push(mixed $data, float $timeout = -1): bool;

    /**
     * Estrae dati dal canale, supporta il timeout (unità di timeout in secondi), restituisce false in caso di timeout
     */
    public function pop(float $timeout = -1): mixed;

    /**
     * Ottiene la lunghezza dei dati nel canale
     */
    public function length(): int;

    /**
     * Ottiene la capacità del canale
     */
    public function getCapacity(): int;

    /**
     * Verifica se ci sono consumatori, ovvero se ci sono coroutine in attesa di estrarre dati
     */
    public function hasConsumers(): bool;

    /**
     * Verifica se ci sono produttori, ovvero se ci sono coroutine in attesa di inviare dati nel canale
     */
    public function hasProducers(): bool;

    /**
     * Chiude il canale
     */
    public function close(): void;

}