From 5ffec900d70a990215f8f260c71412f13a784995 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Mon, 1 Mar 2021 18:06:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 HttpServer/Events/OnWorkerStart.php | 26 ++++++++++++--------------
 1 file changed, 12 insertions(+), 14 deletions(-)

diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php
index 51de2130..f3b2593f 100644
--- a/HttpServer/Events/OnWorkerStart.php
+++ b/HttpServer/Events/OnWorkerStart.php
@@ -91,23 +91,21 @@ class OnWorkerStart extends Callback
 	 * @param $server
 	 * @param $worker_id
 	 * @return mixed
+	 * @throws ComponentException
 	 */
-	public function onSignal(Server $server, $worker_id): void
+	public function onSignal(Server $server, $worker_id): mixed
 	{
 		$ret = Coroutine::waitSignal($this->signal, -1);
-		Coroutine\go(function ($ret, Server $server, $worker_id) {
-			var_dump($server->worker_pid);
-			if ($server->getWorkerStatus() == false) {
-				return 0;
-			}
-			if ($server->getWorkerStatus() == 3) {
-				return 0;
-			}
-			if ($ret === true) {
-				$this->ticker();
-			}
-			return $server->stop($worker_id);
-		}, $ret, $server, $worker_id);
+		if ($server->getWorkerStatus() == false) {
+			return 0;
+		}
+		if ($server->getWorkerStatus() == 3) {
+			return 0;
+		}
+		if ($ret === true) {
+			$this->ticker();
+		}
+		return $server->stop();
 	}