Skip to content

Commit d453743

Browse files
committed
Remove initial jitter for dispatcher
It was always zero for the default polling interval, so it was doing nothing and we didn't even realise ^_^U
1 parent e554e7e commit d453743

File tree

3 files changed

+0
-15
lines changed

3 files changed

+0
-15
lines changed

lib/solid_queue/dispatcher.rb

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -46,10 +46,6 @@ def stop_concurrency_maintenance
4646
concurrency_clerk.stop
4747
end
4848

49-
def initial_jitter
50-
Kernel.rand(0...polling_interval)
51-
end
52-
5349
def metadata
5450
super.merge(batch_size: batch_size, concurrency_maintenance_interval: concurrency_clerk&.interval)
5551
end

lib/solid_queue/processes/base.rb

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -5,15 +5,6 @@ module Processes
55
class Base
66
include Callbacks # Defines callbacks needed by other concerns
77
include AppExecutor, Registrable, Interruptible, Procline
8-
9-
private
10-
def observe_initial_delay
11-
interruptible_sleep(initial_jitter)
12-
end
13-
14-
def initial_jitter
15-
0
16-
end
178
end
189
end
1910
end

lib/solid_queue/processes/runnable.rb

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,7 @@ module Runnable
99
def start
1010
@stopping = false
1111

12-
observe_initial_delay
1312
run_callbacks(:boot) { boot }
14-
1513
start_loop
1614
end
1715

0 commit comments

Comments
 (0)