lib/isono/thread_pool.rb
# Immediatly shutdown all the worker threads
Immediatly shutdown all the worker threads
Immediatly shutdown all the worker threads
def shutdown()
      @worker_threads.each {|id, t|
        t.__send__(:raise, WorkerTerminateError)
        Thread.pass
      }
    end
def shutdown ( ) @worker_threads . each { | id , t | t . __send__ ( :raise , WorkerTerminateError ) Thread . pass } end
Immediatly shutdown all the worker threads
Immediatly shutdown all the worker threads