completable-future 相关问题

在Java 8中，可以显式完成的Future（设置其值和状态），并且可以包括在完成时触发的依赖函数和动作。

我有这段代码： CompletableFuture timeoutFuture = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])) .orTimeout(1, TimeUnit.SECONDS); // 设置一个

java multithreading asynchronous future completable-future

回答 1 投票 0

Java Future 对象在 onComplete 之后从 API 返回值

我有一个如下所示的 API 方法，该方法返回 ResponseEntity。我不知道如何等待它并在 Future onComplete 方法中返回值。公共响应实体我有一个如下所示的 API 方法，该方法返回 ResponseEntity<JsonNode>。我不知道如何等待它并在 Future onComplete 方法中返回值。 public ResponseEntity<JsonNode> doSomeAction( @ApiParam(name = "mode", required = true) @PathVariable final String mode, @RequestBody SomeAction action, HttpServletRequest request) throws IOException) { if(mode.equals("POWER"){ Future<JsonObject> future = someAppService.generatePower(action); future.onComplete( result -> { return new ResponseEntity<JsonNode>(JsonHelper.toJsonNode(result.result().encode()), HttpStatus.OK) //above return is not valid but i want to return here as soon as future completes }); } if(mode.equals("someOtherMode"){ //some code here } return new ResponseEntity<JsonNode>(JsonHelper.getObjectMapper().valueToTree(someResponse), headers, HttpStatus.OK); } 基本上，我想在 onComplete 方法中返回值，即在执行generatePower()方法之后，该方法在内部调用一些API，这可能需要一些时间。我尝试使用 DeferredResult<JsonNode> 但它不起作用。有什么想法吗？您可以使用 CountDownLatch 来等待结果： public ResponseEntity<JsonNode> doSomeAction( @ApiParam(name = "mode", required = true) @PathVariable final String mode, @RequestBody SomeAction action, HttpServletRequest request) throws IOException) { ResponseEntity<JSonObbject> result = null; CountDownLatch ready = new CountDownLatch(1); if(mode.equals("POWER"){ Future<JsonObject> future = someAppService.generatePower(action); future.onComplete( result -> { result = new ResponseEntity<JsonNode>(JsonHelper.toJsonNode(result.result().encode()), HttpStatus.OK) ready.countDown(); }); } if(mode.equals("someOtherMode"){ //code that updates result variable } if (!ready.await(timeout, SECONDS) { // return error or throw appropriate exception } return result; }

java completable-future

回答 1 投票 0

thenCompose 什么时候对 Java 中的 CompletableFuture 有意义

我是 Java 异步编程新手，并试图了解何时使用 thenCompose() 方法有意义。考虑以下伪代码： CompletableFuture 第一个步骤 = CompletableFu...

java completable-future

回答 1 投票 0

Java 意外的异步行为

我期待 Java 中出现意外行为（Java 17，Spring Boot 应用程序）。该方法用于测试，我直接从主方法调用它。主线程不应该被阻塞在...

java asynchronous completable-future java-threads

回答 1 投票 0

Unittest验证异步方法Java

我想验证当运行方法A时，我的代码通过方法B运行（1次），如下所示公共类A类{ @注入 @Named("执行者") ExecutionContextExecutor

java unit-testing concurrency completable-future

回答 1 投票 0

Java 8 到 Java 17 ThreadLocal 问题

我有在Java 8中运行良好的代码，但是当我将其迁移到Java 17时，它就不起作用了。它涉及到ThreadLocal和CompletableFuture.runAsync。以下是课程：公共类 UriParameterHandl...

java multithreading completable-future java-17 thread-local

回答 2 投票 0

Java8 到 Java17 ThreadLocal 问题

我的代码在 Java8 中运行良好，但当我将其迁移到 Java17 时却不起作用。涉及到ThreadLocal和CompletableFuture.runAsync。以下是课程：公共类 UriParameterHandler ...

java multithreading completable-future java-17 thread-local

回答 1 投票 0

无法调用 toCompletableFuture()，因为在使用返回 CompletionStage 的方法时 apply(Object) 的返回值为 null<Void>

我陷入了一个错误： java.util.concurrent.CompletionException：java.lang.NullPointerException：无法调用“java.util.concurrent.CompletionStage.toCompletableFuture()”，因为...

java nullpointerexception completable-future

回答 1 投票 0

我可以使用 CompletableFuture 重复方法直到值为 true

我有一个 Java 方法，可以从数据库表单元格中获取值。我们将其命名为 jdbcTemplate.queryForObject() 我想每 2 分钟运行一次这个方法，直到单元格的值变为 true....

java spring-boot java-8 completable-future

回答 2 投票 0

使用 Mockito 测试 CompletableFuture.supplyAsync

我正在尝试使用mockito测试 CompletableFuture.supplyAsync 函数，但测试未完成可能是因为可完成的未来没有返回。我不确定我在

java spring-boot junit mockito completable-future

回答 2 投票 0

测量CompletableFuture链中的单个执行时间

我有几个异步 api 调用组合在一起形成一个完整的 future 链。链的每个部分都取决于前一个阶段，即如果前一个调用返回非空数据，那么我们就跳过...