class Concurrent::RubyThreadPoolExecutor
def ns_add_busy_worker
-
(nil, Worker)
- nil of max capacity is reached
def ns_add_busy_worker return if @pool.size >= @max_length @workers_counter += 1 @pool << (worker = Worker.new(self, @workers_counter)) @largest_length = @pool.length if @pool.length > @largest_length worker end