Resultados da pesquisa a pedido "completable-future"

1 a resposta

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 = ...

2 a resposta

Qual é a maneira recomendada de esperar até que os futuros threads concluíveis terminem

estou usandoCompletableFuture como mostrado abaixo no código. Mas com relação à maneira como devo esperar até que todas as executáveis terminem, encontrei duas maneiras e não sei a diferença entre elas e qual é a melhor prática? Eles são ...

1 a resposta

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 ...

2 a resposta

Como escolher um executor para CompletableFuture :: supplyAsync

CompletableFuture::supplyAsync(() -> IO bound queries) Como escolhi um Executor para CompletableFuture :: supplyAsync para evitar poluir oForkJoinPool.commonPool(). Existem muitas opções emExecutors (newCachedThreadPool, ...

3 a resposta

CompletableFuture: À espera do primeiro retorno normalmente?

eu tenho algunsCompletableFuturese eu quiser executá-los em paralelo, esperando o primeiro que retornarnormalmente. Eu sei que posso usarCompletableFuture.anyOf esperar o primeiro retornar, mas isso retornaránormalmenteouexcepcionalmente. Eu ...

2 a resposta

Encadeando vários CompletionStage apenas se uma condição for alcançada

Tenho váriosCompletionStage métodos que eu gostaria de encadear. O problema é que o resultado do primeiro determinará se os próximos devem ser executados. No momento, a única maneira de conseguir isso parece passar os argumentos "especiais" para ...

1 a resposta

Como falhar em um java.util.concurrent.Future

Existe um uso bastante pesado deio.vertx.core.Future no ecossistema vertx: https: //vertx.io/docs/apidocs/io/vertx/core/Future.htm [https://vertx.io/docs/apidocs/io/vertx/core/Future.html] Um exemplo de uso do VertxFuture é aqui private ...