lib/async/container/threaded.rb in async-container-0.8.0 vs lib/async/container/threaded.rb in async-container-0.8.1

- old
+ new

@@ -41,11 +41,11 @@ @reactors = concurrency.times.collect do Async::Reactor.new end @threads = @reactors.collect do |reactor| - Thread.new do - thread = Thread.current + ::Thread.new do + thread = ::Thread.current thread.abort_on_exception = true thread.name = name if name begin