优化队列消费者创建新协程消费消息

Author: Yurunsoft

src/Service/BaseQueueConsumer.php

@@ -17,6 +17,7 @@
 use Yurun\Swoole\CoPool\CoPool;
 use Yurun\Swoole\CoPool\Interfaces\ICoTask;
 use Yurun\Swoole\CoPool\Interfaces\ITaskParam;
+use function Yurun\Swoole\Coroutine\goWait;
 
 /**
  * 队列消费基类.
@@ -81,15 +82,17 @@ public function start(?int $co = null): void
                     }
                     else
                     {
-                        Event::trigger('IMI.QUEUE.CONSUMER.BEFORE_CONSUME', [
-                            'queue'     => $queue,
-                            'message'   => $message,
-                        ], $this, ConsumerBeforeConsumeParam::class);
-                        $this->consume($message, $queue);
-                        Event::trigger('IMI.QUEUE.CONSUMER.AFTER_CONSUME', [
-                            'queue'     => $queue,
-                            'message'   => $message,
-                        ], $this, ConsumerAfterConsumeParam::class);
+                        goWait(function () use ($queue, $message) {
+                            Event::trigger('IMI.QUEUE.CONSUMER.BEFORE_CONSUME', [
+                                'queue'     => $queue,
+                                'message'   => $message,
+                            ], $this, ConsumerBeforeConsumeParam::class);
+                            $this->consume($message, $queue);
+                            Event::trigger('IMI.QUEUE.CONSUMER.AFTER_CONSUME', [
+                                'queue'     => $queue,
+                                'message'   => $message,
+                            ], $this, ConsumerAfterConsumeParam::class);
+                        });
                     }
                 }
                 catch (\Throwable $th)