We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c66fd9f commit c159082Copy full SHA for c159082
lib/concurrent/executor/ruby_thread_pool_executor.rb
@@ -226,7 +226,7 @@ def ns_add_busy_worker
226
return if @pool.size >= @max_length
227
228
@workers_counter += 1
229
- @pool << (worker = Worker.new(self, id: @workers_counter))
+ @pool << (worker = Worker.new(self, @workers_counter))
230
@largest_length = @pool.length if @pool.length > @largest_length
231
worker
232
end
@@ -295,7 +295,7 @@ def ns_reset_if_forked
295
class Worker
296
include Concern::Logging
297
298
- def initialize(pool, id: nil)
+ def initialize(pool, id)
299
# instance variables accessed only under pool's lock so no need to sync here again
300
@queue = Queue.new
301
@pool = pool
0 commit comments