class Concurrent::RubyThreadPoolExecutor

def ns_execute(*args, &task)
  ns_reset_if_forked
  if ns_assign_worker(*args, &task) || ns_enqueue(*args, &task)
    @scheduled_task_count += 1
  else
    return fallback_action(*args, &task)
  end
  ns_prune_pool if @next_gc_time < Concurrent.monotonic_time
  nil
end