lib/async/container/threaded.rb in async-container-0.12.0 vs lib/async/container/threaded.rb in async-container-0.13.0

- old
+ new

@@ -51,10 +51,12 @@ def self.multiprocess? false end def initialize + super + @threads = [] @running = true @statistics = Statistics.new end @@ -104,9 +106,10 @@ end # Gracefully shut down all reactors. def stop(graceful = true) @running = false + super if graceful @threads.each{|thread| thread.raise(Interrupt)} else @threads.each(&:kill)