## xgo + Channel 協程基本用法： [>> 到 GitHub 查看 DEMO <<](https://github.com/mix-php/mix-skeleton/tree/v2.1/app/Console/Commands/CoroutineCommand.php) ### 講解 - 首先使用 xgo 方法，以閉包的形式開啟一個協程。 - 接下來在 for 循環中，使用 xgo 以 callable 的方式啟動子協程，并傳遞一個 Channel 參數。 - 代碼在 `xgo([$this, 'foo'], $chan);` 那里并不會阻塞，而是繼續往下執行 - 執行到 `$chan->pop()` 時，由于 sql 查詢還未執行，于是當前協程阻塞，釋放執行流到 `foo` 方法中執行sql - 當 sql 執行完時， `$chan->pop()` 被喚醒并返回數據，繼續往下執行。 - 直到循環執行完畢，`println` 打印總執行時間。 - 輸出 `Time: 5s ` 說明兩次 SQL 查詢是并行執行的。 ## `xgo` 方法 >[danger] 該方法內部有框架異常處理邏輯封裝，不可使用 swoole 原生的 go 方法替代 ``` // 與 swoole 原生 go 方法一樣，支持閉包 xgo(function () { }); // 還擴展了支持直接調用方法，并附帶參數 xgo([$this, 'foo'], $chan); ``` ## `Swoole\Coroutine\Channel` 全部方法： - `push`：放入對象 - `pop`：拋出對象 - `isEmpty`：是否為空 - `isFull`：是否已滿 - `stats`：返回狀態信息 - `length`：返回長度 - `close`：關閉通道