<?php
declare(strict_types=1);
use Swoole\Coroutine;
use Swoole\Database\RedisConfig;
use Swoole\Database\RedisPool;
use Swoole\Runtime;


Runtime::enableCoroutine();
$s = microtime(true);
Coroutine\run(function () {
    $pool = new RedisPool((new RedisConfig)
            ->withHost('127.0.0.1')
        ->withPort(6379)
        ->withAuth('')
        ->withDbIndex(0)
        ->withTimeout(1),1000
    );
    Coroutine::create(function () use ($pool) {
        while (1) {
            $redis = $pool->get();
            $data_pop = $redis->blPop("cdr", 3);//无任务时,阻塞等待
            echo '运行后内存：' . memory_get_usage() . PHP_EOL;
            $pool->put($redis);
            if (!$data_pop) {
                continue;
            }
            if ($this->child < $this->maxProcesses) {
                $this->child++;
                $process = new swoole_process([$this, 'process']);
                $process->write(json_encode($data_pop));//写入到swoole_process进程中
                $pid = $process->start();//进程启动
            }
        }
    });
});

$s = microtime(true) - $s;
echo 'Use ' . $s . 's for queries' . PHP_EOL;