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