চ্যানেল Coroutine চ্যানেল

চ্যানেল হল Coroutine-এর মধ্যে যোগাযোগের একটি মেকানিজম। একটি Coroutine চ্যানেলে ডেটা পাঠাতে পারে, এবং অন্য একটি Coroutine সেখান থেকে ডেটা বের করে আনতে পারে, ফলে 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 সার্ভার
$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)); // প্রতিক্রিয়া: ["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;

    /**
     * কি কোনও কনজিউমার আছে, অর্থাৎ কি কোনও Coroutine ডেটা pop করার জন্য অপেক্ষা করছে
     */
    public function hasConsumers(): bool;

    /**
     * কি কোনও প্রযোজক আছে, অর্থাৎ কি কোনও Coroutine চ্যানেলে ডেটা push করার জন্য অপেক্ষা করছে
     */
    public function hasProducers(): bool;

    /**
     * চ্যানেল বন্ধ করুন
     */
    public function close(): void;

}