发送数据协程调度
最后更新于：2022-04-02 06:29:52
# 发送数据协程调度
[TOC]
## 现状
现在`Server/Client->send`在缓存区已满的情况下，会直接返回`false`，需要借助`onBufferFull`和`onBufferEmpty`这样复杂的事件通知机制才能实现任务的暂停和恢复。
在实现需要大量发送的场景下，现有机制虽然可以实现，但非常复杂。
## 思路
现在基于协程可以实现一种机制，直接在当前协程内`yield`，等待数据发送完成，缓存区清空时，自动`resume`当前协程，继续`send`数据。
* `Server/Client->send`返回`false`并且错误码为`SW_ERROR_OUTPUT_BUFFER_OVERFLOW`时，不返回`false`到`php`层，而是`yield`挂起当前协程
* `Server/Client`监听`onBufferEmpty`事件，在该事件触发后，缓存区内的数据已被发送完毕，这时`resume`对应的协程
* 协程恢复后，继续调用`Server/Client->send`向缓存区内写入数据，这时因为缓存区已空，发送必然是成功的
## 实例
#### 改进前
~~~
for ($i = 0; $i < 100; $i++)
{
//在缓存区塞满时会直接返回`false`
$server->send($fd, $data_2m);
}
~~~
#### 改进后
~~~
for ($i = 0; $i < 100; $i++)
{
//在缓存区塞满时会 yield 当前协程，发送完成后 resume 继续向下执行
$server->send($fd, $data_2m);
}
~~~
## 选项
此项特性会改变底层的默认行为，因此需要额外的一个参数来开启。
~~~
$serv->set([
'send_yield' => true,
]);
~~~
## 影响范围
* `Swoole\Server::send`
* `Swoole\Http\Response::write`
* `Swoole\WebSocket\Server::push`
* `Swoole\Coroutine\Client::send`
* `Swoole\Coroutine\Http\Client::push`
';