111

core/Pool/Pool.php

@@ -48,14 +48,12 @@ class Pool extends Component
     protected function pop(Channel $channel, $retain_number): void
     {
         while ($channel->length() > $retain_number) {
-            if (Context::inCoroutine()) {
             $connection = $channel->pop();
             if ($connection instanceof StopHeartbeatCheck) {
                 $connection->stopHeartbeatCheck();
             }
         }
     }
-    }
 
 
     /**

http-server/Worker/OnServerWorker.php

@@ -83,9 +83,9 @@ class OnServerWorker extends \Server\Abstracts\Server
      */
     public function onWorkerExit(Server $server, int $workerId)
     {
-        $this->eventDispatch->dispatch(new OnWorkerExit($server, $workerId));
-
         ServerManager::setEnv('state', 'exit');
+
+        $this->eventDispatch->dispatch(new OnWorkerExit($server, $workerId));
     }