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 () {
// ...
});
```
';