Телеграмм чат группы jvmchat страница 18396

Size: a a a

pro.jvm

2021 March 05

господа сеньёры/конкаренси мастера, помогите плз, я чёт туплю, видимо:


  CompletableFuture<Integer> fastRequest =
      CompletableFuture.supplyAsync(() -> new Random().nextInt(100));
  CompletableFuture<Integer> slowRequest =
      CompletableFuture.supplyAsync(
          () -> {
            try {
              Thread.sleep(1000);
            } catch (InterruptedException e) {
              throw new RuntimeException(e);
            }
            return 42;
          });

  return fastRequest.thenApply(
      result -> {
        if (result == 42) {
          return result;
        }

        try {
          return slowRequest.get();
        } catch (InterruptedException | ExecutionException e) {
          throw new RuntimeException(e);
        }
      });
}

как сделать эту логику полностью неблокируемой?

источник

00:14пожаловаться #1

Ivan Zemlyankiy in pro.jvm

Ну типа есть 2 запроса,один быстрый но не точный, а второй медленный, но точный. Нужно их соединить так чтобы на второй запрос пользователь забил, если первый вернул что нужно

источник

00:15пожаловаться #2

Ivan Zemlyankiy in pro.jvm

Само собой хочется обойтись без внешних хранилищ типа атомик референсов

источник

00:17пожаловаться #3

Andrei K in pro.jvm

Там есть что-то типа CompletableFuture.any()

источник

00:17пожаловаться #4

Andrei K in pro.jvm

Первый из

источник

00:18пожаловаться #5

Ivan Zemlyankiy in pro.jvm

Andrei K

Там есть что-то типа CompletableFuture.any()

Ну эни не подходит же тоже

источник

00:18пожаловаться #6

Andrei K in pro.jvm

Почему?

источник

00:18пожаловаться #7

Ivan Zemlyankiy in pro.jvm

Ммм... ну да, в той постановке что я дал подходит. Но оригинальная задача у меня именно если первый ответил - значит берём его, если там ничего, то ждём второй

источник

00:20пожаловаться #8

Ivan Zemlyankiy in pro.jvm

вот так, наверное, правильнее спросить:

  CompletableFuture<Boolean> fastRequest =
      CompletableFuture.supplyAsync(() -> new Random().nextBoolean());
  CompletableFuture<Integer> slowRequest =
      CompletableFuture.supplyAsync(
          () -> {
            try {
              Thread.sleep(1000);
            } catch (InterruptedException e) {
              throw new RuntimeException(e);
            }
            return 41;
          });

    return fastRequest.thenApply(
        result -> {
          if (result) {
            return 42;
          } else {
            try {
              return slowRequest.get() + 1;
            } catch (InterruptedException | ExecutionException e) {
              throw new RuntimeException(e);
            }
          }
        });

источник

00:30пожаловаться #9

Ivan Zemlyankiy in pro.jvm

Ivan Zemlyankiy

вот так, наверное, правильнее спросить:

  CompletableFuture<Boolean> fastRequest =
      CompletableFuture.supplyAsync(() -> new Random().nextBoolean());
  CompletableFuture<Integer> slowRequest =
      CompletableFuture.supplyAsync(
          () -> {
            try {
              Thread.sleep(1000);
            } catch (InterruptedException e) {
              throw new RuntimeException(e);
            }
            return 41;
          });

    return fastRequest.thenApply(
        result -> {
          if (result) {
            return 42;
          } else {
            try {
              return slowRequest.get() + 1;
            } catch (InterruptedException | ExecutionException e) {
              throw new RuntimeException(e);
            }
          }
        });

как сделать эту пипяку неблокируемой?

источник

00:30пожаловаться #10

Evgeniy ♎️ in pro.jvm

Ivan Zemlyankiy

как сделать эту пипяку неблокируемой?

то есть вы хотите в медленном запросе сэкономить время быстрого запроса?

источник

00:32пожаловаться #11

Evgeniy ♎️ in pro.jvm

не проще дёрнуть быстрый и спокойно в зависимости от ответа дёрнуть или нет медленный

источник

00:33пожаловаться #12

Yurii Melnychuk in pro.jvm

Ivan Zemlyankiy

вот так, наверное, правильнее спросить:

  CompletableFuture<Boolean> fastRequest =
      CompletableFuture.supplyAsync(() -> new Random().nextBoolean());
  CompletableFuture<Integer> slowRequest =
      CompletableFuture.supplyAsync(
          () -> {
            try {
              Thread.sleep(1000);
            } catch (InterruptedException e) {
              throw new RuntimeException(e);
            }
            return 41;
          });

    return fastRequest.thenApply(
        result -> {
          if (result) {
            return 42;
          } else {
            try {
              return slowRequest.get() + 1;
            } catch (InterruptedException | ExecutionException e) {
              throw new RuntimeException(e);
            }
          }
        });

CompletableFuture<Boolean> fastRequest =
    CompletableFuture.supplyAsync(() -> new Random().nextBoolean());
CompletableFuture<Integer> slowRequest =
    CompletableFuture.supplyAsync(
        () -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            return 41;
        });

return fastRequest.thenCompose(
    result -> {
        if (result) {
            return CompletableFuture.completedFuture(42);
        } else {
            return slowRequest.thenApply(i -> i + 1);
        }
    });

источник

00:37пожаловаться #13

Ivan Zemlyankiy in pro.jvm

Evgeniy ♎️

то есть вы хотите в медленном запросе сэкономить время быстрого запроса?

да, именно так

источник

00:37пожаловаться #14

Ivan Zemlyankiy in pro.jvm

Evgeniy ♎️

не проще дёрнуть быстрый и спокойно в зависимости от ответа дёрнуть или нет медленный

нет, быстрый - он относительно быстрый )

источник

00:38пожаловаться #15

Ivan Zemlyankiy in pro.jvm

Yurii Melnychuk

CompletableFuture<Boolean> fastRequest =
    CompletableFuture.supplyAsync(() -> new Random().nextBoolean());
CompletableFuture<Integer> slowRequest =
    CompletableFuture.supplyAsync(
        () -> {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            return 41;
        });

return fastRequest.thenCompose(
    result -> {
        if (result) {
            return CompletableFuture.completedFuture(42);
        } else {
            return slowRequest.thenApply(i -> i + 1);
        }
    });