助力软件开发企业降本增效 PHP / java源码系统,只需一次付费,代码终身使用! 广告
# Process\\Pool->start [TOC] 启动工作进程。 ~~~ function Process\Pool::start() : bool; ~~~ * 启动成功,当前进程进入`wait`状态,管理工作进程 * 启动失败,返回`false`,可使用`swoole_errno`获取错误码 ~~~ $workerNum = 10; $pool = new Swoole\Process\Pool($workerNum); $pool->on("WorkerStart", function ($pool, $workerId) { echo "Worker#{$workerId} is started\n"; $redis = new Redis(); $redis->pconnect('127.0.0.1', 6379); $key = "key1"; while (true) { $msgs = $redis->brpop($key, 2); if ( $msgs == null) continue; var_dump($msgs); } }); $pool->on("WorkerStop", function ($pool, $workerId) { echo "Worker#{$workerId} is stopped\n"; }); $pool->start(); ~~~ ## 进程管理 * 某个工作进程遇到致命错误、主动退出时管理器会进行回收,避免出现僵尸进程 * 工作进程退出后,管理器会自动拉起、创建一个新的工作进程 * 主进程收到`SIGTERM`信号时将停止`fork`新进程,并`kill`所有正在运行的工作进程 * 主进程收到`SIGUSR1`信号时将将逐个`kill`正在运行的工作进程,并重新启动新的工作进程 ## 信号处理 底层仅设置了主进程(管理进程)的信号处理,并未对`Worker`工作进程设置信号,需要开发者自行实现信号的监听。 * 工作进程为异步模式,请使用`Swoole\Process::signal`监听信号 * 工作进程为同步模式,请使用`pcntl_signal`和`pcntl_signal_dispatch`监听信号 在工作进程中应当监听`SIGTERM`信号,当主进程需要终止该进程时,会向此进程发送`SIGTERM`信号。如果工作进程未监听`SIGTERM`信号,底层会强行终止当前进程,造成部分逻辑丢失。 ~~~ $pool->on("WorkerStart", function ($pool, $workerId) { $running = true; pcntl_signal(SIGTERM, function () use (&$running) { $running = false; }); echo "Worker#{$workerId} is started\n"; $redis = new Redis(); $redis->pconnect('127.0.0.1', 6379); $key = "key1"; while ($running) { $msg = $redis->brpop($key); pcntl_signal_dispatch(); if ( $msgs == null) continue; var_dump($msg); } }); ~~~