class method self.new

# File activesupport/lib/active_support/testing/parallelization/test_distributor.rb, line 78
        def initialize(worker_count:)
          @worker_count = worker_count
          @queues = Array.new(@worker_count) { Queue.new }
          @next_worker = 0
          @mutex = Mutex.new
          @cv = ConditionVariable.new
          @closed = false
        end