lib/bundler/worker.rb in bundler-2.2.29 vs lib/bundler/worker.rb in bundler-2.2.30

@@ -19,11 +19,11 @@
     # @param size [Integer] Size of pool
     # @param name [String] name the name of the worker
     # @param func [Proc] job to run in inside the worker pool
     def initialize(size, name, func)
       @name = name
-      @request_queue = Queue.new
-      @response_queue = Queue.new
+      @request_queue = Thread::Queue.new
+      @response_queue = Thread::Queue.new
       @func = func
       @size = size
       @threads = nil
       @previous_interrupt_handler = nil
     end