class Concurrent::RubyThreadPoolExecutor

def execute(*args, &task)
  prune_pool
  if ensure_capacity?
    @scheduled_task_count += 1
    @queue << [args, task]
  else
    handle_overflow(*args, &task) if @max_queue != 0 && @queue.length >= @max_queue
  end
end