$swooleServer
$swooleServer : \PG\MSF\MSFServer
Class AsynPoolManager
$swooleServer : \PG\MSF\MSFServer
__construct(\swoole_process $process, \PG\MSF\MSFServer $swooleServer)
AsynPoolManager constructor.
\swoole_process | $process | 进程对象 |
\PG\MSF\MSFServer | $swooleServer | Server运行实例 |
registerAsyn(\PG\MSF\Pools\IAsynPool $asyn) : $this
注册异步连接池
\PG\MSF\Pools\IAsynPool | $asyn | 连接池对象 |
writePipe(\PG\MSF\Pools\IAsynPool $asyn, mixed $data, integer $workerId) : $this
写入管道
\PG\MSF\Pools\IAsynPool | $asyn | 连接池对象 |
mixed | $data | 写入数据 |
integer | $workerId | worker进程ID |
sendMessageToWorker(\PG\MSF\Pools\IAsynPool $asyn, mixed $data) : $this
分发消息给worker
\PG\MSF\Pools\IAsynPool | $asyn | 连接池对象 |
mixed | $data | 待分发数据 |