def METHOD_NAME(self, timeout=None):
    with type(self)._POOL_LOCK:
        if not self.is_shutdown:
            raise AsyncArcticException("The workers pool has not been shutdown, please call shutdown() first.")
    LazySingletonTasksCoordinator.wait_tasks(
        [v[0] for v in self.alive_tasks.values()],
        timeout=timeout, return_when=ALL_COMPLETED, raise_exceptions=False)
    with type(self)._POOL_LOCK:
        self.alive_tasks = {}