Repository navigation
新增通道容器
- 新增通道容器
use Yurun\Swoole\CoPool\ChannelContainer;
go(function(){
$channelContainer = new ChannelContainer;
$id = 'abc';
$data = [
'time' => time(),
];
go(function() use($id, $data, $channelContainer){
echo 'Wait 3 seconds...', PHP_EOL;
\Swoole\Coroutine::sleep(3);
$channelContainer->push($id, $data);
});
var_dump($channelContainer->pop($id));
});