From 43d0596c12cc7ad2b7fa2fce861d3762d73b490d Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Tue, 20 Jul 2021 01:57:37 +0800
Subject: [PATCH] modify

---
 Server/Worker/ServerWorker.php | 116 +++++++++++++++++----------------
 1 file changed, 59 insertions(+), 57 deletions(-)

diff --git a/Server/Worker/ServerWorker.php b/Server/Worker/ServerWorker.php
index 5398cb9c..979511e6 100644
--- a/Server/Worker/ServerWorker.php
+++ b/Server/Worker/ServerWorker.php
@@ -19,71 +19,73 @@ class ServerWorker extends \Server\Abstracts\Server
 {
 
 
-	/**
-	 * @param Server $server
-	 * @param int $workerId
-	 * @throws Exception
-	 */
-	public function onWorkerStart(Server $server, int $workerId)
-	{
-		$annotation = Snowflake::app()->getAnnotation();
-		$annotation->read(APP_PATH);
-		$this->runEvent(Constant::WORKER_START, null, [$server, $workerId]);
-		if ($workerId >= $server->setting['worker_num'] + 1) {
-			$annotation->runtime(CONTROLLER_PATH);
-		}
-		Event::trigger(Event::SERVER_ON_WORKER_START, [$server, $workerId]);
-		name($server->worker_pid, 'Worker.' . $workerId);
-	}
+    /**
+     * @param Server $server
+     * @param int $workerId
+     * @throws Exception
+     */
+    public function onWorkerStart(Server $server, int $workerId)
+    {
+        $this->_setConfigCache($workerId);
+        $annotation = Snowflake::app()->getAnnotation();
+        $annotation->read(APP_PATH);
+
+        $this->runEvent(Constant::WORKER_START, null, [$server, $workerId]);
+        if ($workerId >= $server->setting['worker_num'] + 1) {
+            $annotation->runtime(CONTROLLER_PATH);
+        }
+        Event::trigger(Event::SERVER_ON_WORKER_START, [$server, $workerId]);
+        name($server->worker_pid, 'Worker.' . $workerId);
+    }
 
 
-	/**
-	 * @param $worker_id
-	 * @throws Exception
-	 */
-	private function setConfigs($worker_id)
-	{
-		putenv('state=start');
-		putenv('worker=' . $worker_id);
+    /**
+     * @param $worker_id
+     * @throws Exception
+     */
+    private function _setConfigCache($worker_id)
+    {
+        putenv('state=start');
+        putenv('worker=' . $worker_id);
 
-		$serialize = file_get_contents(storage(Runtime::CONFIG_NAME));
-		if (empty($serialize)) {
-			return;
-		}
-		Config::sets(unserialize($serialize));
-	}
+        $serialize = file_get_contents(storage(Runtime::CONFIG_NAME));
+        if (empty($serialize)) {
+            return;
+        }
+        Config::sets(unserialize($serialize));
+    }
 
 
-	/**
-	 * @param Server $server
-	 * @param int $workerId
-	 */
-	public function onWorkerStop(Server $server, int $workerId)
-	{
-		$this->runEvent(Constant::WORKER_STOP, null, [$server, $workerId]);
-	}
+    /**
+     * @param Server $server
+     * @param int $workerId
+     */
+    public function onWorkerStop(Server $server, int $workerId)
+    {
+        $this->runEvent(Constant::WORKER_STOP, null, [$server, $workerId]);
+    }
 
 
-	/**
-	 * @param Server $server
-	 * @param int $workerId
-	 */
-	public function onWorkerExit(Server $server, int $workerId)
-	{
-		$this->runEvent(Constant::WORKER_EXIT, null, [$server, $workerId]);
-	}
+    /**
+     * @param Server $server
+     * @param int $workerId
+     */
+    public function onWorkerExit(Server $server, int $workerId)
+    {
+        $this->runEvent(Constant::WORKER_EXIT, null, [$server, $workerId]);
+    }
 
 
-	/**
-	 * @param Server $server
-	 * @param int $worker_id
-	 * @param int $worker_pid
-	 * @param int $exit_code
-	 * @param int $signal
-	 */
-	public function onWorkerError(Server $server, int $worker_id, int $worker_pid, int $exit_code, int $signal)
-	{
-		$this->runEvent(Constant::WORKER_ERROR, null, [$server, $worker_id, $worker_pid, $exit_code, $signal]);
-	}
+    /**
+     * @param Server $server
+     * @param int $worker_id
+     * @param int $worker_pid
+     * @param int $exit_code
+     * @param int $signal
+     */
+    public function onWorkerError(Server $server, int $worker_id, int $worker_pid, int $exit_code, int $signal)
+    {
+        $this->runEvent(Constant::WORKER_ERROR, null, [$server, $worker_id, $worker_pid, $exit_code, $signal]);
+    }
 
 }