[Messenger] subtract event handling time from sleep time in worker

nicolas-grekas · nicolas-grekas · commit 3b9457eb2be6 · 2021-10-19T10:46:09.000+02:00
diff --git a/src/Symfony/Component/Messenger/Worker.php b/src/Symfony/Component/Messenger/Worker.php
@@ -113,10 +113,13 @@ public function run(array $options = []): void
                 }
             }
 
-            if (false === $envelopeHandled) {
+            if (!$envelopeHandled) {
+                $start = microtime(true);
                 $this->dispatchEvent(new WorkerRunningEvent($this, true));
 
-                usleep($options['sleep']);
+                if (0 < $sleep = (int) ($options['sleep'] - 1e6 * (microtime(true) - $start))) {
+                    usleep((int) $sleep);
+                }
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -113,10 +113,13 @@ public function run(array $options = []): void`
`113`	`113`	`}`
`114`	`114`	`}`
`115`	`115`
`116`		`- if (false === $envelopeHandled) {`
	`116`	`+ if (!$envelopeHandled) {`
	`117`	`+ $start = microtime(true);`
`117`	`118`	`$this->dispatchEvent(new WorkerRunningEvent($this, true));`
`118`	`119`
`119`		`- usleep($options['sleep']);`
	`120`	`+ if (0 < $sleep = (int) ($options['sleep'] - 1e6 * (microtime(true) - $start))) {`
	`121`	`+ usleep((int) $sleep);`
	`122`	`+ }`
`120`	`123`	`}`
`121`	`124`	`}`
`122`	`125`