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)