修复 Workerman 下队列进程残留 (#485)

* 修复 Workerman 下队列进程残留

* 修复

src/Components/queue/src/Process/WorkermanQueueConsumerProcess.php

@@ -7,6 +7,7 @@
 use Imi\Aop\Annotation\Inject;
 use Imi\Log\Log;
 use Imi\Queue\Service\QueueService;
+use Imi\Workerman\Hook\Timer;
 use Imi\Workerman\Process\Annotation\Process;
 use Imi\Workerman\Process\BaseProcess;
 use Imi\Workerman\Process\ProcessManager;
@@ -30,6 +31,7 @@ class WorkermanQueueConsumerProcess extends BaseProcess
 
         public function run(Worker $worker): void
         {
+            Timer::clear();
             WorkermanServerWorker::clearAll();
 
             WorkermanServerUtil::initWorkermanWorker('QueueConsumer');

src/Components/workerman/src/Hook/Timer.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Imi\Workerman\Hook;
+
+class Timer extends \Workerman\Timer
+{
+    public static function clear(): void
+    {
+        static::delAll();
+        // @phpstan-ignore-next-line
+        static::$_event = null;
+        static::$_timerId = 0;
+    }
+}

src/Components/workerman/src/Server/Server.php

@@ -21,6 +21,7 @@ class Server extends \Imi\Server\Server
      */
     public static function initWorkermanWorker(?string $serverName = null): void
     {
+        WorkermanServerWorker::$stopTimeout = 3;
         $config = Config::get('@app.workerman.worker', []);
         foreach ($config as $key => $value)
         {