协程 Channel

    使用方式

    1. use \Imi\Util\CoroutineChannelManager;
    3. // 获取 Swoole\Coroutine\Channel 对象
    4. $channel = CoroutineChannelManager::getInstance('name1');
    6. // 向队列中加入一个成员
    7. CoroutineChannelManager::push('name1', 'test');
    8. // 还支持数组，等一切可以被序列化的值
    9. CoroutineChannelManager::push('name1', [1, 2, 3]);
    11. $result = CoroutineChannelManager::pop('name1');
    13. // 获取通道的状态
    14. $result = CoroutineChannelManager::stats('name');
    15. /*
    16. $result 格式如下：
    17. [
    18.     // 消费者数量，表示当前通道为空，有N个协程正在等待其他协程调用push方法生产数据
    19.     'consumer_num'    =>    1,
    20.     // 生产者数量，表示当前通道已满，有N个协程正在等待其他协程调用pop方法消费数据
    21.     'producer_num'  =>    1,
    22.     // 通道中的元素数量
    24.     'queue_bytes'    =>    1024,
    25. ]
    26. */
    28. // 关闭通道。并唤醒所有等待读写的协程。
    29. CoroutineChannelManager::close('name1');
    31. // 通道读写检测
    32. // $channel1和2 都是 Swoole\Coroutine\Channel 对象
    33. $read = [$channel1];
    34. $write = [$channel2];
    35. $result = CoroutineChannelManager::select('name1', $read, $write, 0.001);