Есть ли у CompletableFuture соответствующий локальный контекст?

CompletableFuture # whenComplete не вызывается, если thenApply используется

У меня есть следующий код (в результатемой предыдущий вопрос), который планирует задачу на удаленном сервере, а затем опрашивает для завершения, используя

Это то, что я обнаружил и в других местах. Забыл вернуться и обновить вопрос снова. Так что ответ принимается :)

ичок в лямбдах и асинхронном коде в Java 8. Я продолжаю получать странные результаты ...У меня есть следующий код:

Ответ теперь выглядит намного лучше @Valery. Я удалил свой предыдущий комментарий, так как он больше не актуален.

у меня есть

 метод.

исал следующий код: System.out.println("Main thread:" + Thread.currentThread().getId()); CompletableFuture<Void> future = CompletableFuture.runAsync(() -> { try { System.out.println("Before sleep thread:" + Thread.currentThread().getId(), + ...

@sindhu_sp Обновлен мой ответ, чтобы быть более понятным.

я есть вопрос о методе CompletableFuture: public <U> CompletableFuture<U> thenApply(Function<? super T, ? extends U> fn) Дело в том, что JavaDoc говорит именно это: Возвращает новый CompletionStage, который, когда этот этап ...

 с поставщиком

я есть сомнения по поводу этого кода: @Async public CompletableFuture<String> doFoo() { CompletableFuture<String> fooFuture = new CompletableFuture<>(); try { String fooResult = longOp(); fooFuture.complete(fooResult); } catch (Exception e) ...

 будущее…

оложим, у меня есть следующий код: CompletableFuture<Integer> future = CompletableFuture.supplyAsync( () -> 0); thenApply кейс: future.thenApply( x -> x + 1 ) .thenApply( x -> x + 1 ) .thenAccept( x -> System.out.println(x));Здесь вывод будет ...

, но из твоих примеров тебя нет.

ел пример в каждом из них, но мне нужно точно знать, в чем разница в глубине, потому что иногда я думаю, что могу использовать оба из них, чтобы получить тот же результат, поэтому я хочу знать, чтобы я мог выбрать правильный один? какая польза ...

Итак, как я могу убить эти асинхронные операции?

я есть метод, который проверяет время выполнения CompletableFuture. Если такое CompletableFuture выполняется более 2 секунд, я хочу убить эту задачу. Но как я могу это сделать, если у меня нет контрольного потока, где выполняются ...