修复多进程消费时重复触发进程池stop的操作 (#710)

Eno-CN · web-flow · commit 14e4be7e1d0f · 2024-08-10T08:01:56.000+08:00
diff --git a/src/Components/queue/src/Partial/SwooleBaseQueueConsumerPartial.php b/src/Components/queue/src/Partial/SwooleBaseQueueConsumerPartial.php
@@ -90,11 +90,11 @@ public function run(ITaskParam $param)
          */
         public function stop(): void
         {
-            $this->working = false;
-            if ($this->coPool)
+            if ($this->working)
             {
                 $this->coPool->stop();
             }
+            $this->working = false;
         }
 
         protected function task(QueueConfig $config): void

Original file line number	Diff line number	Diff line change
`@@ -90,11 +90,11 @@ public function run(ITaskParam $param)`
`90`	`90`	`*/`
`91`	`91`	`public function stop(): void`
`92`	`92`	`{`
`93`		`- $this->working = false;`
`94`		`- if ($this->coPool)`
	`93`	`+ if ($this->working)`
`95`	`94`	`{`
`96`	`95`	`$this->coPool->stop();`
`97`	`96`	`}`
	`97`	`+ $this->working = false;`
`98`	`98`	`}`
`99`	`99`
`100`	`100`	`protected function task(QueueConfig $config): void`