Searched refs:queue_impl (Results 1 – 1 of 1) sorted by relevance
47 def __init__(self, tests, num_jobs, queue_impl, canceled_flag): argument51 self.queue = queue_impl()216 queue_impl = multiprocessing.Queue227 queue_impl = queue.Queue232 provider = TestProvider(self.tests, jobs, queue_impl, canceled_flag)