Searched refs:_COPY_POOL (Results 1 – 2 of 2) sorted by relevance
284 self._old_pool = training_utils_v1._COPY_POOL288 training_utils_v1._COPY_POOL = MonitoredPool(293 training_utils_v1._COPY_POOL = self._old_pool382 self.assertEqual(training_utils_v1._COPY_POOL._apply_counter, 2)387 training_utils_v1._COPY_POOL._func_wrapper = add_sleep394 training_utils_v1._COPY_POOL._func_wrapper = cause_error
315 _COPY_POOL = None variable327 global _COPY_POOL328 if _COPY_POOL is None:329 _COPY_POOL = multiprocessing.pool.ThreadPool(_COPY_THREADS)330 atexit.register(_COPY_POOL.close)331 return _COPY_POOL