diff --git a/lib/rukawa/context.rb b/lib/rukawa/context.rb index 43a29dd..fbd251d 100644 --- a/lib/rukawa/context.rb +++ b/lib/rukawa/context.rb @@ -6,7 +6,6 @@ def initialize(concurrency = nil) @concurrency = concurrency || Rukawa.config.concurrency @store = Concurrent::Hash.new @executor = Concurrent::CachedThreadPool.new - @executor.auto_terminate = true @semaphore = Concurrent::Semaphore.new(@concurrency) end