Join 4,000+ others and never miss out on new tips, tutorials, and more.
4.x is outdated, please check the latest version 22.x
Latest version:
pecl install openswoole-22.1.2
<?php Swoole\Coroutine\Channel->push(mixed $data, float $timeout = -1): bool
The data you want to add to the channel stack, can be any PHP variable, including anonymous functions and resources.
Sets the timeout period for when the channel is full, false will be returned if the timeout is reached
A successful push will return true and a closed channel or timeout will return false.
Writes data to the channel.
Wait and push one element into the queue of the channel.
<?php
$chan = new Swoole\Coroutine\Channel(1);
Co\run(function () use ($chan) {
$cid = Swoole\Coroutine::getuid();
$i = 0;
while (1) {
co::sleep(1);
$chan->push(['rand' => rand(1000, 9999), 'index' => $i]);
echo "[coroutine $cid] - $i\n";
$i++;
}
});
Co\run(function () use ($chan) {
$cid = Swoole\Coroutine::getuid();
while(1) {
$data = $chan->pop();
echo "[coroutine $cid]\n";
var_dump($data);
}
});
Coroutine channels use local memory, memory is isolated between different processes. Only in same process push and pop operations work with different coroutines.
You can use $channel->errCode to access the error code for more detail on what happened.
To avoid ambiguity, do not write data into an empty channel that could be classed as an error, such as
0,false, an empty string ornull.