Csp 并發模式
使用 子協程(go)
+ 通道(channel)
實現 Csp
并發模式并發執行。
當我們需要并發執行某些不相干的請求,并得到結果的時候,例如:
$sql1->exec();
$sql2->exec();
$sql2->exec();
在以上的代碼中,我們沒辦法最大的節約時間,因為 sql
語句都是順序執行的,因此我們引入了 Csp
并發編程的概念。
示例代碼
<?php
go(function () {
$channel = new \Swoole\Coroutine\Channel();
go(function () use ($channel) {
// 模擬執行sql
\co::sleep(0.1);
$channel->push(1);
});
go(function () use ($channel) {
// 模擬執行sql
\co::sleep(0.1);
$channel->push(2);
});
go(function () use ($channel) {
// 模擬執行sql
\co::sleep(0.1);
$channel->push(3);
});
$i = 3;
while ($i--) {
var_dump($channel->pop());
}
});
當然,在以上的代碼中,我們沒有充分地考慮超時等情況
進一步封裝
<?php
go(function () {
$csp = new \EasySwoole\Component\Csp();
$csp->add('t1', function () {
\co::sleep(0.1);
return 't1 result';
});
$csp->add('t2', function () {
\co::sleep(0.1);
return 't2 result';
});
var_dump($csp->exec());
});
exec
方法提供了一個默認參數:超時時間(默認為 5s
),當調用 $csp->exec()
后,最長等待 5s
左右會返回結果。如果你在 t2
函數中 co::sleep(6)
,那么 5s
后,返回的數據中不會包含 t2
函數的返回數據。