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