Resultados da pesquisa a pedido "completable-future"
Como criar traços de pilha assíncronos?
ATUALIZAR: A versão mais recente do Intellij IDEAimplementa [https://www.jetbrains.com/help/idea/tutorial-java-debugging-deep-dive.html#async_stacktraces] exatamente o que estou procurando. A questão é como implementar isso fora do IDE (para que ...
CompletableFuture # whenComplete não chamado se thenApply for usado
Eu tenho o seguinte código (resultante deminha pergunta anterior [https://stackoverflow.com/questions/40251528/how-to-use-executorservice-to-poll-until-a-result-arrives] ) que agenda uma tarefa em um servidor remoto e, em seguida, busca a ...
Como obtenho um CompletableFuture <T> de uma solicitação do cliente HTTP assíncrono?
EmDocumentação do cliente assíncrono Http [https://github.com/AsyncHttpClient/async-http-client]Eu vejo como conseguir umFuture<Response> como resultado de uma solicitação HTTP Get assíncrona, basta fazer, por exemplo: AsyncHttpClient ...
CompletableFuture não está sendo executado. Se eu usar o pool ExecutorService, seu trabalho conforme o esperado, mas não com o pool comum forkJoin padrão
Eu estou tentando executar a seguinte classe está sendo finalizada sem executar o CompletableFuture. public class ThenApplyExample { public static void main(String[] args) throws Exception { //ExecutorService es = ...
Em qual thread os manipuladores de conclusão do CompletableFuture são executados?
Tenho uma pergunta sobre o método CompletableFuture: public <U> CompletableFuture<U> thenApply(Function<? super T, ? extends U> fn)A questão é que o JavaDoc diz exatamente isso: Retorna um novo CompletionStage que, quando esse estágio é ...
Mapear exceções em um futuro completável para um tipo de exceção diferente?
Estou usando o futuro completo do java 8 e gostaria de poder fazer uma exceção lançada pelo futuro e transformá-la em uma exceção diferente. Todo o material composto que tentei parece ter um curto-circuito quando ocorre uma exceção. Usando um ...
Qual é a diferença entre thenApply e thenApplyAsync do Java CompletableFuture?
Suponha que eu tenha o seguinte código: CompletableFuture<Integer> future = CompletableFuture.supplyAsync( () -> 0); thenApply caso: future.thenApply( x -> x + 1 ) .thenApply( x -> x + 1 ) .thenAccept( x -> System.out.println(x));Aqui a saída ...
O CompletionStage sempre quebra exceções no CompletionException?
oCompletionStage [https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/CompletionStage.html] Javadoc afirma: [...] se o cálculo de um estágio terminar abruptamente com uma exceção ou erro (não verificado), todos os estágios dependentes ...
Por que o CompletableFuture.supplyAsync está obtendo um número aleatório de vezes?
Eu sou novo nos códigos lambdas e assíncrono no Java 8. Continuo obtendo alguns resultados estranhos ... Eu tenho o seguinte código: import java.util.concurrent.CompletableFuture; public class Program { public static void main(String[] args) { ...
CompletableFuture tem um contexto local correspondente?
Antigamente, tínhamos o ThreadLocal para os programas transportarem dados junto com o caminho da solicitação, pois todo o processamento da solicitação era feito nesse segmento e coisas como o logback usavam isso com MDC.put ...