Channel 协程通道

Channel เป็นกลไกการสื่อสารระหว่างโครูทีน (coroutine) โครูทีนหนึ่งสามารถส่งข้อมูลไปยังช่องทาง และอีกโครูทีนสามารถดึงข้อมูลออกจากช่องทางนั้น ทำให้สามารถทำงานร่วมกันและแชร์ข้อมูลระหว่างโครูทีนได้

提示
ฟีเจอร์นี้ต้องการ 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('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)); // Response: ["Task 1 Done","Task 2 Done"]
};
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;

    /**
     * มีผู้บริโภคหรือไม่ หมายถึงว่ามีโครูทีนที่รอคอยการดึงข้อมูลอยู่
     */
    public function hasConsumers(): bool;

    /**
     * มีผู้ผลิตหรือไม่ หมายถึงว่ามีโครูทีนที่รอคอยการส่งข้อมูลไปยังช่องทาง
     */
    public function hasProducers(): bool;

    /**
     * ปิดช่องทาง
     */
    public function close(): void;

}