lib/bolt/executor.rb in bolt-0.20.2 vs lib/bolt/executor.rb in bolt-0.20.3

@@ -25,10 +25,10 @@
         coll[key.to_s] = Concurrent::Delay.new { val.new }
       end
 
       @noop = noop
       @run_as = nil
-      @pool = Concurrent::CachedThreadPool.new(max_threads: @config[:concurrency])
+      @pool = Concurrent::ThreadPoolExecutor.new(max_threads: @config[:concurrency])
       @logger.debug { "Started with #{@config[:concurrency]} max thread(s)" }
       @notifier = Bolt::Notifier.new
     end
 
     def transport(transport)