This commit is contained in:
2021-02-26 19:31:04 +08:00
parent 9c5ec61d06
commit a5318aa79f
+4 -2
View File
@@ -8,6 +8,7 @@ use Exception;
use HttpServer\Abstracts\Callback;
use Snowflake\Abstracts\Config;
use Snowflake\Event;
use Snowflake\Exception\ComponentException;
use Snowflake\Exception\ConfigException;
use Snowflake\Snowflake;
use Swoole\Coroutine;
@@ -53,6 +54,7 @@ class OnWorkerStart extends Callback
* @param Server $server
* @param int $workerId
* 异步任务管制
* @throws ComponentException
*/
public function onTaskSignal(Server $server, int $workerId)
{
@@ -62,8 +64,8 @@ class OnWorkerStart extends Callback
return $server->stop($workerId);
}
var_dump(env('workerId') . '::' . $server->getWorkerStatus($workerId));
var_dump(env('workerId') . '::' . $server->stats()['coroutine_num']);
$this->error(env('workerId') . '::' . $server->getWorkerStatus($workerId));
$this->error(env('workerId') . '::' . $server->stats()['coroutine_num']);
while ($server->getWorkerStatus($workerId) === SWOOLE_WORKER_BUSY) {
Coroutine::sleep(0.01);