class Concurrent::RubyThreadPoolExecutor

def ns_add_busy_worker

Returns:
  • (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