class Concurrent::RubyExecutorService

def shutdown

def shutdown
  synchronize do
    break unless running?
    self.ns_auto_terminate = false
    stop_event.set
    ns_shutdown_execution
  end
  true
end