diff --git a/Annotation/Annotation.php b/Annotation/Annotation.php
index 8122ce86..8f9895dd 100644
--- a/Annotation/Annotation.php
+++ b/Annotation/Annotation.php
@@ -6,7 +6,9 @@ namespace Annotation;
 
 use DirectoryIterator;
 use Exception;
+use ReflectionException;
 use Snowflake\Abstracts\Component;
+use Snowflake\Exception\NotFindClassException;
 
 /**
  * Class Annotation
@@ -166,6 +168,8 @@ class Annotation extends Component
 
 	/**
 	 * @param object $class
+	 * @throws ReflectionException
+	 * @throws NotFindClassException
 	 */
 	public function injectProperty(object $class)
 	{
@@ -189,10 +193,10 @@ class Annotation extends Component
 
 	/**
 	 * @param string $dir
-	 * @param string|array $outPath
+	 * @return array
 	 * @throws Exception
 	 */
-	public function runtime(string $dir)
+	public function runtime(string $dir): array
 	{
 		return $this->_loader->loadByDirectory($dir);
 	}
diff --git a/Annotation/Loader.php b/Annotation/Loader.php
index 9c44bede..59a6c5f4 100644
--- a/Annotation/Loader.php
+++ b/Annotation/Loader.php
@@ -165,20 +165,20 @@ class Loader extends BaseObject
 
 	/**
 	 * @param string $path
-	 * @param string|array $outPath
+	 * @return array
 	 * @throws Exception
 	 */
-	public function loadByDirectory(string $path)
+	public function loadByDirectory(string $path): array
 	{
 		try {
 			$path = '/' . trim($path, '/');
-
 			$paths = [];
 			foreach (static::$_directory as $key => $_path) {
 				$key = '/' . trim($key, '/');
 				if (!str_starts_with($key, $path)) {
 					continue;
 				}
+				unset(static::$_directory[$key]);
 				foreach ($_path as $item) {
 					$paths[] = $item;
 				}
diff --git a/Server/Worker/ServerWorker.php b/Server/Worker/ServerWorker.php
index 2cb849a5..2fad98de 100644
--- a/Server/Worker/ServerWorker.php
+++ b/Server/Worker/ServerWorker.php
@@ -11,7 +11,6 @@ use Snowflake\Event;
 use Snowflake\Exception\ConfigException;
 use Snowflake\Runtime;
 use Snowflake\Snowflake;
-use Swoole\Coroutine;
 use Swoole\Server;
 use Swoole\Timer;
 
@@ -24,134 +23,135 @@ class ServerWorker extends \Server\Abstracts\Server
 {
 
 
-    /**
-     * @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 . 'app');
+	/**
+	 * @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 . 'app');
 
-        $this->runEvent(Constant::WORKER_START, null, [$server, $workerId]);
+		$this->runEvent(Constant::WORKER_START, null, [$server, $workerId]);
 
-        $this->workerInitExecutor($server, $annotation, $workerId);
-    }
+		$this->workerInitExecutor($server, $annotation, $workerId);
+		$annotation->runtime(APP_PATH . 'app');
+	}
 
 
-    /**
-     * @param Server $server
-     * @param Annotation $annotation
-     * @param int $workerId
-     * @throws ConfigException
-     * @throws Exception
-     */
-    private function workerInitExecutor(Server $server, Annotation $annotation, int $workerId)
-    {
-        if ($workerId < $server->setting['worker_num']) {
-            $loader = Snowflake::app()->getRouter();
-            $loader->_loader();
+	/**
+	 * @param Server $server
+	 * @param Annotation $annotation
+	 * @param int $workerId
+	 * @throws ConfigException
+	 * @throws Exception
+	 */
+	private function workerInitExecutor(Server $server, Annotation $annotation, int $workerId)
+	{
+		if ($workerId < $server->setting['worker_num']) {
+			$loader = Snowflake::app()->getRouter();
+			$loader->_loader();
 
-            echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m Worker[%d].%d start.", $server->worker_pid, $workerId) . PHP_EOL;
-            $this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
-        } else {
-            echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m Tasker[%d].%d start.", $server->worker_pid, $workerId) . PHP_EOL;
+			echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m Worker[%d].%d start.", $server->worker_pid, $workerId) . PHP_EOL;
+			$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
+		} else {
+			echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m Tasker[%d].%d start.", $server->worker_pid, $workerId) . PHP_EOL;
 
-            $this->setProcessName(sprintf('Tasker[%d].%d', $server->worker_pid, $workerId));
-        }
-    }
+			$this->setProcessName(sprintf('Tasker[%d].%d', $server->worker_pid, $workerId));
+		}
+	}
 
 
-    /**
-     * @param $worker_id
-     * @throws Exception
-     */
-    private function _setConfigCache($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
-     * @throws Exception
-     */
-    public function onWorkerStop(Server $server, int $workerId)
-    {
-        $this->runEvent(Constant::WORKER_STOP, null, [$server, $workerId]);
+	/**
+	 * @param Server $server
+	 * @param int $workerId
+	 * @throws Exception
+	 */
+	public function onWorkerStop(Server $server, int $workerId)
+	{
+		$this->runEvent(Constant::WORKER_STOP, null, [$server, $workerId]);
 
-        Event::trigger(Event::SERVER_WORKER_STOP);
+		Event::trigger(Event::SERVER_WORKER_STOP);
 
-        fire(Event::SYSTEM_RESOURCE_CLEAN);
+		fire(Event::SYSTEM_RESOURCE_CLEAN);
 
-        Timer::clearAll();
-    }
+		Timer::clearAll();
+	}
 
 
-    /**
-     * @param Server $server
-     * @param int $workerId
-     * @throws Exception
-     */
-    public function onWorkerExit(Server $server, int $workerId)
-    {
-        $this->runEvent(Constant::WORKER_EXIT, null, [$server, $workerId]);
+	/**
+	 * @param Server $server
+	 * @param int $workerId
+	 * @throws Exception
+	 */
+	public function onWorkerExit(Server $server, int $workerId)
+	{
+		$this->runEvent(Constant::WORKER_EXIT, null, [$server, $workerId]);
 
-        putenv('state=exit');
+		putenv('state=exit');
 
-        Event::trigger(Event::SERVER_WORKER_EXIT, [$server, $workerId]);
+		Event::trigger(Event::SERVER_WORKER_EXIT, [$server, $workerId]);
 
-        Snowflake::getApp('logger')->insert();
-    }
+		Snowflake::getApp('logger')->insert();
+	}
 
 
-    /**
-     * @param Server $server
-     * @param int $worker_id
-     * @param int $worker_pid
-     * @param int $exit_code
-     * @param int $signal
-     * @throws Exception
-     */
-    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
+	 * @throws Exception
+	 */
+	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]);
 
-        Event::trigger(Event::SERVER_WORKER_ERROR);
+		Event::trigger(Event::SERVER_WORKER_ERROR);
 
-        $message = sprintf('Worker#%d::%d error stop. signal %d, exit_code %d, msg %s',
-            $worker_id, $worker_pid, $signal, $exit_code, swoole_strerror(swoole_last_error(), 9)
-        );
-        write($message, 'worker-exit');
+		$message = sprintf('Worker#%d::%d error stop. signal %d, exit_code %d, msg %s',
+			$worker_id, $worker_pid, $signal, $exit_code, swoole_strerror(swoole_last_error(), 9)
+		);
+		write($message, 'worker-exit');
 
-        $this->system_mail($message);
-    }
+		$this->system_mail($message);
+	}
 
 
-    /**
-     * @param $messageContent
-     * @throws Exception
-     */
-    protected function system_mail($messageContent)
-    {
-        try {
-            $email = Config::get('email');
-            if (!empty($email) && ($email['enable'] ?? false) == true) {
-                Help::sendEmail($email, 'Service Error', $messageContent);
-            }
-        } catch (\Throwable $e) {
-            error($e, 'email');
-        }
-    }
+	/**
+	 * @param $messageContent
+	 * @throws Exception
+	 */
+	protected function system_mail($messageContent)
+	{
+		try {
+			$email = Config::get('email');
+			if (!empty($email) && ($email['enable'] ?? false) == true) {
+				Help::sendEmail($email, 'Service Error', $messageContent);
+			}
+		} catch (\Throwable $e) {
+			error($e, 'email');
+		}
+	}
 
 }