改名

HttpServer/Events/OnFinish.php

@@ -26,8 +26,6 @@ class OnFinish extends Callback
 		$data = json_decode($data, true);
 		$data['work_id'] = $task_id;
 		$this->write(var_export($data, true), 'Task');
-
-		Snowflake::app()->decrement();
 	}
 
 }

HttpServer/Events/OnTask.php

@@ -99,6 +99,9 @@ class OnTask extends Callback
 	private function runTaskHandler($data): ?array
 	{
 		Snowflake::app()->increment();
+		defer(function () {
+			Snowflake::app()->decrement();
+		});
 		try {
 			$serialize = $this->before($data);
 			$params = $serialize->getParams();

HttpServer/Events/OnWorkerStart.php

@@ -41,6 +41,9 @@ class OnWorkerStart extends Callback
 		if (!empty($get_name) && !Snowflake::isMac()) {
 			swoole_set_process_name($get_name);
 		}
+
+		Snowflake::app()->stateInit();
+
 		putenv('workerId=' . ($worker_id >= $server->setting['worker_num'] ? 'Task' : 'Worker') . '.' . $worker_id);
 		if ($worker_id >= $server->setting['worker_num']) {
 			fire(Event::SERVER_TASK_START);

System/Abstracts/BaseApplication.php

@@ -93,6 +93,13 @@ abstract class BaseApplication extends Service
 	}
 
 
+	public function stateInit()
+	{
+		$this->taskNumber = 0;
+		$this->state = 'SWOOLE_WORKER_IDLE';
+	}
+
+
 	public function decrement()
 	{
 		$this->taskNumber -= 1;