Fix queue processing timeout

Author: papac

src/Queue/Adapters/QueueAdapter.php

@@ -103,11 +103,12 @@ public function sleep(int $seconds): void
     /**
      * Update the processing timeout
      *
+     * @param int $timeout
      * @return void
      */
-    public function updateProcessingTimeout(): void
+    public function updateProcessingTimeout(int $timeout = 60): void
     {
-        $this->processing_timeout = time();
+        $this->processing_timeout = time() + $timeout;
     }
 
     /**
@@ -119,15 +120,15 @@ public function updateProcessingTimeout(): void
      */
     final public function work(int $timeout, int $memory): void
     {
-        [$this->processing_timeout, $jobs_processed] = [time(), 0];
+        [$this->processing_timeout, $jobs_processed] = [time() + $timeout, 0];
 
         if ($this->supportsAsyncSignals()) {
             $this->listenForSignals();
         }
 
         while (true) {
             try {
-                $this->updateProcessingTimeout();
+                $this->updateProcessingTimeout($timeout);
                 $this->run($this->queue);
             } finally {
                 $this->sleep($this->sleep);