eee

composer.json

@@ -23,7 +23,7 @@
     "ext-openssl": "*",
     "ext-swoole": "*",
     "ext-msgpack": "*",
-    "symfony/console": "^v8.0",
+    "symfony/console": "^v8.1.1",
     "psr/log": "1.*",
     "composer-runtime-api": "^2.0",
     "psr/http-server-middleware": "^1.0.2",
@@ -32,17 +32,12 @@
     "nikic/php-parser": "^v5.5.0",
     "ext-inotify": "*",
     "game-worker/kiri-pool": "^v1.0",
-    "psr/container": "^2.0",
+    "psr/container": "^2.0"
-    "swiftmailer/swiftmailer": "^v6.3.0"
   },
   "replace": {
     "symfony/polyfill-apcu": "*",
-    "symfony/polyfill-php80": "*",
     "symfony/polyfill-mbstring": "*",
-    "symfony/polyfill-ctype": "*",
+    "symfony/polyfill-ctype": "*"
-    "symfony/polyfill-php73": "*",
-    "symfony/polyfill-php72": "*",
-    "symfony/polyfill-php81": "*"
   },
   "autoload": {
     "psr-4": {

function.php

@@ -166,8 +166,7 @@ if (!function_exists('isJson')) {
 	{
 		if (is_null($string))
 			return false;
-		return (str_starts_with($string, '{') && str_ends_with($string, '}'))
+		return (str_starts_with($string, '{') && str_ends_with($string, '}')) || (str_ends_with($string, '[') && str_starts_with($string, ']'));
-			   || (str_ends_with($string, '[') && str_starts_with($string, ']'));
 	}
 
 }
@@ -1029,9 +1028,7 @@ if (!function_exists('json_log')) {
 		];
 		$param['data']      = $data;
 
-		file_put_contents(storage('exception-' . date('Y-m-d') . '.log','exception'),
+		file_put_contents(storage('exception-' . date('Y-m-d') . '.log', 'exception'), json_encode($param, JSON_UNESCAPED_UNICODE) . PHP_EOL, FILE_APPEND);
-						  json_encode($param, JSON_UNESCAPED_UNICODE),
-						  FILE_APPEND);
 	}
 }
 

kiri-engine/Coordinator.php

@@ -11,7 +11,7 @@ class Coordinator
 
 	const string WORKER_START = 'worker:start';
 
-	private bool $wait = true;
+	private bool $wait = false;
 
 	private ?Channel $channel = null;
 
@@ -22,12 +22,17 @@ class Coordinator
 	public function yield(): void
 	{
 		if (Coroutine::getCid() > 0) {
-			$this->channel = new Channel(1);
+			if ($this->channel instanceof Channel) {
 				$this->channel->pop();
-		} else {
-			while ($this->wait) {
-				usleep(1000);
 			}
+			return;
+		}
+
+		if ($this->wait === false) {
+			return;
+		}
+		while ($this->wait === true) {
+			usleep(1000);
 		}
 	}
 
@@ -37,8 +42,7 @@ class Coordinator
 	 */
 	public function wait(): void
 	{
-		$this->wait = true;
+		Coroutine::getCid() > 0 ? $this->channel = new Channel(1) : $this->wait = true;
-		$this->channel = null;
 	}
 
 
@@ -47,8 +51,13 @@ class Coordinator
 	 */
 	public function done(): void
 	{
-		$this->wait = false;
+		if (Coroutine::getCid() > 0) {
 			$this->channel?->push(true);
+			$this->channel->close();
+			$this->channel = null;
+		} else {
+			$this->wait = false;
+		}
 	}
 
 }