class ActiveSupport::Testing::Parallelization
def initialize(worker_count)
def initialize(worker_count) @worker_count = worker_count @queue_server = Server.new @worker_pool = [] @url = DRb.start_service("drbunix:", @queue_server).uri end
def initialize(worker_count) @worker_count = worker_count @queue_server = Server.new @worker_pool = [] @url = DRb.start_service("drbunix:", @queue_server).uri end