Improve workers and prefetch

Kaspiman · May 10, 2023 · 4fd11ba · 4fd11ba
1 parent 3f89448
commit 4fd11ba
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 10 deletions.
diff --git a/emitter.php b/emitter.php
@@ -24,7 +24,7 @@
 
 $len = count($queues);
 
-for ($i = 0; $i <= 5000; $i++) {
+for ($i = 0; $i < getenv('NUM_WORKERS'); $i++) {
     $q = random_int(0, $len - 1);
 
     $job = $queues[$q]->create('test-1', '{"site": "https://example.com"}');

diff --git a/monitor.php b/monitor.php
@@ -23,5 +23,5 @@
         }
     }
 
-    sleep(1);
+    sleep(3);
 }
diff --git a/rr.yaml b/rr.yaml
@@ -34,7 +34,7 @@ jobs:
             driver: amqp
             config:
                 queue: queue-1
-                prefetch: 10
+                prefetch: 100
                 priority: 0
                 durable: true
                 exchange_durable: true
@@ -44,7 +44,7 @@ jobs:
             driver: amqp
             config:
                 queue: queue-2
-                prefetch: 10
+                prefetch: 100
                 priority: 0
                 durable: true
                 exchange_durable: true
@@ -54,7 +54,7 @@ jobs:
             driver: amqp
             config:
                 queue: queue-3
-                prefetch: 10
+                prefetch: 100
                 priority: 0
                 durable: true
                 exchange_durable: true
@@ -64,7 +64,7 @@ jobs:
             driver: amqp
             config:
                 queue: queue-4
-                prefetch: 10
+                prefetch: 100
                 priority: 0
                 durable: true
                 exchange_durable: true
@@ -74,7 +74,7 @@ jobs:
             driver: amqp
             config:
                 queue: queue-5
-                prefetch: 10
+                prefetch: 100
                 priority: 0
                 durable: true
                 exchange_durable: true

diff --git a/worker.php b/worker.php
@@ -9,9 +9,7 @@
 $consumer = new Consumer();
 
 while (($task = $consumer->waitTask())) {
-    $random = random_int(50, 1000);
-
-    usleep($random * 1000);
+    sleep(10);
 
     $task->complete();
 }