WaitGroup + xdefer

最后更新于:2022-04-02 07:05:12

## WaitGroup + xdefer >[info] WaitGroup 适合不返回处理结果的场景 基本用法: [>> 到 GitHub 查看 DEMO <<](https://github.com/mix-php/mix-skeleton/tree/v2.1/app/Console/Commands/WaitGroupCommand.php) ### 讲解 看完 `xgo + chan` 的 DEMO,我们会发现一个问题:如果子协程中的 SQL 抛出异常,那 `$chan->pop()` 会一直处于阻塞状态,使用 `WaitGroup + xdefer` 的话,就可避免这个问题。 - 启动子协程时计数+1,`$ws->add(1);` - `xdefer` 方法中的闭包,即使协程抛出异常也会执行计数-1,`$ws->done();` - 当全部 `$ws->done();` 完成时,`$ws->wait();` 唤醒并继续执行。 ## `Mix\Concurrent\Sync\WaitGroup` 全部方法: - `add`:增加计数 - `done`:完成计数 - `wait`:等待 ## `xdefer` 方法 >[danger] - 注意 xdefer 是在当前协程结束时触发,并不是在当前 php 方法执行结束时触发 > - 该方法内部有框架异常处理逻辑封装,不可使用 swoole 原生的 go 方法替代 ``` xdefer(function () { // ... }); ```
';