public HealthCheckResponse call() {
String redisHost = this.configuration.getRedisHost();
log.info("connect to redis host: {}", redisHost);
Future redisConnectionFuture = Redis.createClient(Vertx.vertx(), redisHost).connect();
while (!redisConnectionFuture.isComplete()) {
log.debug("waiting for redis connection future complete: ({})", redisConnectionFuture.isComplete());
}
log.info("redis connection future completed, {} and succeded {}", redisConnectionFuture.isComplete(), redisConnectionFuture.succeeded());
if (redisConnectionFuture.isComplete() && redisConnectionFuture.succeeded()) {
return HealthCheckResponse.up("RedisCustomHealthCheck");
}
log.info("sending down RedisCustomHealthCheck");
return HealthCheckResponse.down("RedisCustomHealthCheck");
}
поэтому моя проблема в том, что мне нужно проверить соединение Redis. это асинхронная функция, поэтому я могу установить onSuccess и написать свою логику. там я не могу вернуть HealtCheckResponse. Вопрос: я не хочу ждать с циклом while. какое возможное решение этой проблемы?
У меня проблема с будущим Java и функцией-обработчиком. пример кода: [code]public HealthCheckResponse call() {
String redisHost = this.configuration.getRedisHost(); log.info("connect to redis host: {}", redisHost);
Future redisConnectionFuture = Redis.createClient(Vertx.vertx(), redisHost).connect(); while (!redisConnectionFuture.isComplete()) { log.debug("waiting for redis connection future complete: ({})", redisConnectionFuture.isComplete()); } log.info("redis connection future completed, {} and succeded {}", redisConnectionFuture.isComplete(), redisConnectionFuture.succeeded()); if (redisConnectionFuture.isComplete() && redisConnectionFuture.succeeded()) { return HealthCheckResponse.up("RedisCustomHealthCheck"); } log.info("sending down RedisCustomHealthCheck"); return HealthCheckResponse.down("RedisCustomHealthCheck"); } [/code] поэтому моя проблема в том, что мне нужно проверить соединение Redis. это асинхронная функция, поэтому я могу установить onSuccess и написать свою логику. там я не могу вернуть HealtCheckResponse. Вопрос: я не хочу ждать с циклом while. какое возможное решение этой проблемы?
Я создал приведенный ниже пример, чтобы проиллюстрировать свою проблему. По сути, я перебираю два списка, которые содержат объекты, и использую завершаемые фьючерсы. Я запускаю каждый метод mymethod() для каждого экземпляра моего тестового класса. Я...
Я пишу программу Python, включающую цикл create_task () , которая вызывает асинхронные функции. В каждой задаче он ждет, пока другой поток установит результат для будущего объекта .
async def run(self) -> int:
cur_ts = 0
tasks: List = []
while not...
Я написал действительно простой код, который функционирует как «школьный регистр», спрашивая, присутствует ли ученик или нет; Если что -то другое, кроме «да» или «нет», введено, код просто напечатает «неверный ввод».
Я хотел бы иметь ответ «да» или...
Работа над курсом Java MOOC. Почему while(end > Begin) не сработало, а while(begin под методомbinarySearch
Ссылка на мой код: нажмите здесь
Для моей первоначальной отправки while(end > Begin) не сработало (там проверяли ошибки при отправке), но...