New option WorkerOptions::$backoffMultiplier (default: 1) to define a multiplier for backoff time

Author: ElGigi

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
+## [1.2.0] - 2025-06-25
+
+### Added
+
+- New option `WorkerOptions::$backoffMultiplier` (default: 1) to define a multiplier for backoff time
+
 ## [1.1.0] - 2025-06-05
 
 ### Added

README.md

@@ -117,14 +117,15 @@ $worker->setLogger(new NullLogger());
 
 // Configure worker options
 $options = new WorkerOptions(
-    name: 'worker',   // Worker name
-    limit: 10,        // Max jobs to execute
-    memoryLimit: 128, // Memory limit in MB
-    timeLimit: 60,    // Time limit in seconds
-    killFilePath: 10, // File to kill process
-    sleep: 2,         // Sleep time between jobs in seconds
-    stopNoJob: true,  // Stop if no job
-    backoffTime: 0,   // Time to wait before retry failed job
+    name: 'worker',       // Worker name
+    limit: 10,            // Max jobs to execute
+    memoryLimit: 128,     // Memory limit in MB
+    timeLimit: 60,        // Time limit in seconds
+    killFilePath: 10,     // File to kill process
+    sleep: 2,             // Sleep time between jobs in seconds
+    stopNoJob: true,      // Stop if no job
+    backoffTime: 0,       // Time to wait before retry failed job
+    backoffMultiplier: 1, // Multiplier for backoff time
 );
 
 // Create a queue instance

src/Worker.php

@@ -205,7 +205,7 @@ public function run(QueueInterface $queue, WorkerOptions $options = new WorkerOp
                 );
             } catch (Throwable $exception) {
                 // Release job
-                $job->release($options->backoffTime);
+                $job->release($this->nextDelayAfterFailure($job, $options));
 
                 $this->logger?->error(
                     sprintf(
@@ -237,4 +237,21 @@ public function executeJob(JobInterface $job): void
     {
         $this->jobHandlerManager->handle($job);
     }
+
+    /**
+     * Next delay after job failure.
+     *
+     * @param JobInterface $job
+     * @param WorkerOptions $options
+     *
+     * @return int
+     */
+    public function nextDelayAfterFailure(JobInterface $job, WorkerOptions $options): int
+    {
+        if ($job->getAttempts() <= 1) {
+            return $options->backoffTime;
+        }
+
+        return $options->backoffTime * pow(max($options->backoffMultiplier, 1), $job->getAttempts() - 1);
+    }
 }

src/WorkerOptions.php

@@ -26,6 +26,7 @@ public function __construct(
         public int|float $sleep = 0,
         public int|float $sleepNoJob = 1,
         public int $backoffTime = 0,
+        public int $backoffMultiplier = 1,
     ) {
     }
 
@@ -47,6 +48,7 @@ public function logOptions(?LoggerInterface $logger): void
         $logger?->debug(sprintf('Sleep between job consumption: %s', $this->unit($this->sleep, 'second(s)')));
         $logger?->debug(sprintf('Sleep if no job: %s', $this->unit($this->sleepNoJob, 'second(s)')));
         $logger?->debug(sprintf('Backoff time: %s', $this->unit($this->backoffTime, 'second(s)')));
+        $logger?->debug(sprintf('Backoff multiplier: %s', $this->unit($this->backoffMultiplier)));
     }
 
     private function unit(int|float $value, ?string $unit = null): string

tests/WorkerTest.php

@@ -18,6 +18,7 @@
 use Berlioz\QueueManager\Worker;
 use Berlioz\QueueManager\WorkerExit;
 use Berlioz\QueueManager\WorkerOptions;
+use PHPUnit\Framework\Attributes\DataProvider;
 use PHPUnit\Framework\TestCase;
 use Psr\Log\LoggerInterface;
 use ReflectionClass;
@@ -164,4 +165,60 @@ public function testRunExitsWhenKillFileExists()
 
         unlink($killFile); // Cleanup
     }
+
+    public static function provideJobAndOptionsForDelay()
+    {
+        return [
+            [
+                'jobAttempts' => 1,
+                'backoffTime' => 30,
+                'backoffMultiplier' => 2,
+                'exceptedDelay' => 30,
+            ],
+            [
+                'jobAttempts' => 2,
+                'backoffTime' => 30,
+                'backoffMultiplier' => 2,
+                'exceptedDelay' => 60,
+            ],
+            [
+                'jobAttempts' => 3,
+                'backoffTime' => 30,
+                'backoffMultiplier' => 2,
+                'exceptedDelay' => 120,
+            ],
+            [
+                'jobAttempts' => 4,
+                'backoffTime' => 30,
+                'backoffMultiplier' => 2,
+                'exceptedDelay' => 240,
+            ],
+            [
+                'jobAttempts' => 3,
+                'backoffTime' => 30,
+                'backoffMultiplier' => 1,
+                'exceptedDelay' => 30,
+            ],
+            [
+                'jobAttempts' => 3,
+                'backoffTime' => 1,
+                'backoffMultiplier' => 2,
+                'exceptedDelay' => 4,
+            ],
+        ];
+    }
+
+    #[DataProvider('provideJobAndOptionsForDelay')]
+    public function testNextDelayAfterFailure(
+        int $jobAttempts,
+        int $backoffTime,
+        int $backoffMultiplier,
+        int $exceptedDelay
+    ) {
+        $options = new WorkerOptions(backoffTime: $backoffTime, backoffMultiplier: $backoffMultiplier);
+        $jobMock = $this->createMock(JobInterface::class);
+        $jobMock->method('getAttempts')->willReturn($jobAttempts);
+
+        $this->assertEquals($exceptedDelay, $this->worker->nextDelayAfterFailure($jobMock, $options));
+    }
 }