Searched refs:_join_threads (Results 1 – 2 of 2) sorted by relevance
259 def _join_threads(self, threads): member in DistributeCoordinatorTestBase591 self._join_threads([threads[WORKER][0]])602 self._join_threads(threads[WORKER])616 self._join_threads(threads[WORKER])632 self._join_threads(threads[WORKER])670 self._join_threads(threads[WORKER])694 self._join_threads(threads[WORKER])729 self._join_threads(threads[WORKER])730 self._join_threads([threads[EVALUATOR][0]])
969 MultiThreadedTestCase._join_threads(threads, func)998 self._join_threads(self.threads, fn)1096 def _join_threads(cls, threads, fn): member in MultiThreadedTestCase