Tag: COMPLETABLE-FUTURE
Aquí está una versión de código corto del problema que estoy enfrentando: public static void main(String[] args) { CompletableFuture.supplyAsync(() -> { /* try { Thread.sleep(2000); } catch (InterruptedException ignored) {} */ //System.out.println(“supplyAsync: ” + Thread.currentThread().getName()); return 1; }) .thenApply(i -> { System.out.println(“apply: ” + Thread.currentThread().getName()); return i + 1; }) . . . Read more
Me gustaría realizar una llamada REST asincrónica a DynamoDB utilizando CompletableFuture, y se proporciona el siguiente método: private CompletableFuture<updateitemresult> updateDynamodbAsync(UpdateItemRequest request) { return CompletableFuture.supplyAsync(() -> { UpdateItemResult result = amazonDynamoDBClient.updateItem(request); return result; }); } A continuación, se muestra la ejecución del código: UpdateItemResult result = null; CompletableFuture<updateitemresult> updateItemResultCompletableFuture = updateDynamodbAsync(updateItemRequest); . . . Read more
Estoy buscando una manera de implementar un Collector de CompletableFuture. Quiero decir, mi código actual es el siguiente: private CompletableFuture<><bundleentryresponsecomponent>> makeAllOfCompletableFuture(List<><bundleentryresponsecomponent>> completableFutures) { CompletableFuture<void> allFutures = CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[completableFutures.size()])); CompletableFuture<><bundleentryresponsecomponent>> allCompletableFuture = allFutures.thenApply(future -> { return completableFutures.stream() .map(completableFuture -> completableFuture.join()) .collect(Collectors.toList()); }); CompletableFuture<><bundleentryresponsecomponent>> completableFuture = allCompletableFuture.toCompletableFuture(); return completableFuture; } Como puedes . . . Read more
Me estoy encontrando con un problema en Scala y múltiples futuros en un escenario de “for yield”. Tanto f1 como f2 son futuros. El futuro f2 se basa en un valor obtenido del futuro f1. val result = for { f1 <- Await.result(dao.findNode(“nodeA”), 5 seconds) // Esto devuelve una clase . . . Read more
Tengo un programa que realiza solicitudes HTTP, donde podría necesitar probar varios servidores diferentes para obtener una respuesta exitosa. El cliente HTTP es asíncrono, por lo que obtengo resultados de CompletableFuture al realizar las solicitudes. Puedo intentar fácilmente el “siguiente” servidor cuando obtengo un código de estado de respuesta incorrecto, . . . Read more