PHP 協程：Go + Chan + Defer
Swoole4
提供了強大的PHP CSP
協程程式設計模式。底層提供了3
個關鍵詞，可以方便地實現各類功能。
關鍵詞
go chan defer
這3
個功能底層實現全部為記憶體操作
，沒有任何IO
資源消耗。就像PHP
的Array
一樣是非常廉價的。如果有需要就可以直接使用。這與socket
和file
操作不同，後者需要向作業系統申請埠和檔案描述符，讀寫可能會產生阻塞的IO
等待。
協程併發
使用go
函式可以讓一個函式併發地去執行。在程式設計過程中，如果某一段邏輯可以併發執行，就可以將它放置到go
協程中執行。
順序執行
function test1()
{
sleep(1);
echo "b";
}
function test2()
{
sleep(2);
echo "c";
}
test1();
test2();
執行結果：
htf@LAPTOP-0K15EFQI:~$ time php b1.php bc real0m3.080s user0m0.016s sys0m0.063s htf@LAPTOP-0K15EFQI:~$
上述程式碼中，test1
和test2
會順序執行，需要3
秒才能執行完成。
併發執行
使用go
建立協程，可以讓test1
和test2
兩個函式變成併發執行。
Swoole\Runtime::enableCoroutine();
go(function ()
{
sleep(1);
echo "b";
});
go(function ()
{
sleep(2);
echo "c";
});
執行結果：
bchtf@LAPTOP-0K15EFQI:~$ time php co.php bc real0m2.076s user0m0.000s sys0m0.078s htf@LAPTOP-0K15EFQI:~$
可以看到這裡只用了2
秒就執行完成了。
t1+t2+t3... max(t1, t2, t3, ...)
協程通訊
有了go
關鍵詞之後，併發程式設計就簡單多了。與此同時又帶來了新問題，如果有2
個協程併發執行，另外一個協程，需要依賴這兩個協程的執行結果，如果解決此問題呢？
答案就是使用通道（Channel
），在Swoole4
協程中使用new chan
就可以建立一個通道。通道可以理解為自帶協程排程的佇列。它有兩個介面push
和pop
：
push pop
使用通道可以很方便地實現併發管理 。
$chan = new chan(2);
# 協程1
go (function () use ($chan) {
$result = [];
for ($i = 0; $i < 2; $i++)
{
$result += $chan->pop();
}
var_dump($result);
});
# 協程2
go(function () use ($chan) {
$cli = new Swoole\Coroutine\Http\Client('www.qq.com', 80);
$cli->set(['timeout' => 10]);
$cli->setHeaders([
'Host' => "www.qq.com",
"User-Agent" => 'Chrome/49.0.2587.3',
'Accept' => 'text/html,application/xhtml+xml,application/xml',
'Accept-Encoding' => 'gzip',
]);
$ret = $cli->get('/');
// $cli->body 響應內容過大，這裡用 Http 狀態碼作為測試
$chan->push(['www.qq.com' => $cli->statusCode]);
});
# 協程3
go(function () use ($chan) {
$cli = new Swoole\Coroutine\Http\Client('www.163.com', 80);
$cli->set(['timeout' => 10]);
$cli->setHeaders([
'Host' => "www.163.com",
"User-Agent" => 'Chrome/49.0.2587.3',
'Accept' => 'text/html,application/xhtml+xml,application/xml',
'Accept-Encoding' => 'gzip',
]);
$ret = $cli->get('/');
// $cli->body 響應內容過大，這裡用 Http 狀態碼作為測試
$chan->push(['www.163.com' => $cli->statusCode]);
});
執行結果：
htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$ time php co2.php
array(2) {
["www.qq.com"]=>
int(302)
["www.163.com"]=>
int(200)
}
real0m0.268s
user0m0.016s
sys0m0.109s
htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$
這裡使用go
建立了3
個協程，協程2
和協程3
分別請求qq.com
和163.com
主頁。協程1
需要拿到Http
請求的結果。這裡使用了chan
來實現併發管理。
-
協程
1迴圈兩次對通道進行pop，因為佇列為空，它會進入等待狀態 -
協程
2和協程3執行完成後，會push資料，協程1拿到了結果，繼續向下執行
延遲任務
在協程程式設計中，可能需要在協程退出時自動實行一些任務，做清理工作。類似於PHP
的register_shutdown_function
，在Swoole4
中可以使用defer
實現。
Swoole\Runtime::enableCoroutine();
go(function () {
echo "a";
defer(function () {
echo "~a";
});
echo "b";
defer(function () {
echo "~b";
});
sleep(1);
echo "c";
});
執行結果：
htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$ time php defer.php abc~b~a real0m1.068s user0m0.016s sys0m0.047s htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$
結語
Swoole4
提供的Go + Chan + Defer
為PHP
帶來了一種全新的CSP
併發程式設計模式。靈活使用Swoole4
提供的各項特性，可以解決工作中各類複雜功能的設計和開發。