class Concurrent::RubyExecutorService

def post(*args, &task)
  raise ArgumentError.new('no block given') unless block_given?
  synchronize do
    # If the executor is shut down, reject this task
    return handle_fallback(*args, &task) unless running?
    ns_execute(*args, &task)
    true
  end
end