1234567891011121314151617181920 |
- <?php
- //chan1 block and chan buffer
- $c1 = new chan(1);
- go(function () use ($c1) {
- $start = microtime(1);
- $ret = $c1->pop(1);
- $end = microtime(1);
- echo "chan pop ret:".var_export($ret,1)." error:".$c1->errCode."\n";
- echo "use time:".($end-$start)."s\n";
- });
- go(function () use ($c1) {
- co::sleep(2);
- echo "sleep 2\n";
- $ret = $c1->push("chan-1");
- echo "chan push ret:".var_export($ret,1)." error:".$c1->errCode."\n";
- });
|