Слияние кода завершено, страница обновится автоматически
После запуска появляется ошибка, socket занят.
При небольшой параллельности и достаточном размере пула соединений программа работает.
// Конфигурация опущена
$redis = new BaseRedis();
for ($i = 0; $i < 1000; $i++) {
Coroutine\go(function () use ($i) {
$this->output->info('ii:' . $i);
});
Coroutine\go(function () use ($redis) {
$redis->hset('eq', 'cpu', time());
});
Coroutine\go(function () use ($redis) {
$redis->hset('eq', 'ram', time());
});
Coroutine\go(function () use ($redis) {
$redis->hset('eq', 'disk', time());
});
}
$this->output->info('all:' . json_encode($redis->hgetall('eq')));