Allow running a stopped worker again

src/DefaultWorker.php

@@ -35,11 +35,11 @@
         private readonly EventDispatcherInterface $eventDispatcher,
         private readonly LoggerInterface|null $logger = null,
     ) {
         $this->timeMeasure = static fn () => (int)round(microtime(true) * 1000);
     }
 
     /** @param positive-int|0 $sleepTimer in milliseconds */
     public function run(int $sleepTimer = 1000): void
     {
         $this->logger?->debug('Worker starting');
 
@@ -60,10 +60,10 @@
             $this->eventDispatcher->dispatch(new WorkerRunningEvent($this));
 
             if ($this->shouldStop) {
                 break;
             }
 
             $sleepFor = max($sleepTimer - $ranTime, 0);
 
             if ($sleepFor <= 0) {
                 continue;
@@ -73,6 +73,8 @@
             usleep($sleepFor * 1000);
         }
 
+        $this->shouldStop = false;
+
         $this->logger?->debug('Worker stopped');
 
         $this->eventDispatcher->dispatch(new WorkerStoppedEvent($this));

tests/Unit/DefaultWorkerTest.php

@@ -275,4 +275,39 @@ static function ($stop) use (&$calls): void {
 
         self::assertSame(1, $calls);
     }
+
+    public function testRunWorkerTwice(): void
+    {
+        $calls = 0;
+
+        $worker = new DefaultWorker(
+            static function (callable $stop) use (&$calls): void {
+                $calls++;
+                $stop();
+            },
+            new EventDispatcher(),
+        );
+
+        $worker->run(0);
+        $worker->run(0);
+
+        self::assertSame(2, $calls);
+    }
+
+    public function testStopBeforeRun(): void
+    {
+        $calls = 0;
+
+        $worker = new DefaultWorker(
+            static function () use (&$calls): void {
+                $calls++;
+            },
+            new EventDispatcher(),
+        );
+
+        $worker->stop();
+        $worker->run(0);
+
+        self::assertSame(0, $calls);
+    }
 }