class Concurrent::RubyThreadPoolExecutor

def ns_kill_execution

@!visibility private 
def ns_kill_execution
  # TODO log out unprocessed tasks in queue
  # TODO try to shutdown first?
  @pool.each(&:kill)
  @pool.clear
  @ready.clear
end