文章/答案/技术大牛

发布

社区首页 >问答首页 >CompletableFuture thenAccept不工作

问CompletableFuture thenAccept不工作
EN

Stack Overflow用户

提问于 2022-01-02 17:00:22

回答 1查看 164关注 0票数 0

欢迎，我很困惑为什么这部分代码不能工作。

public class Main {
public static void main(String[] args) throws URISyntaxException {
    final String URL = "https://jsonplaceholder.typicode.com/users/1";

    HttpRequest request = HttpRequest.newBuilder(new URI(URL)).GET().timeout(Duration.of(10, ChronoUnit.SECONDS)).build();

    HttpClient.newHttpClient().sendAsync(request, HttpResponse.BodyHandlers.ofString()).thenAcceptAsync(r -> {
        System.out.println(r.statusCode());
        System.out.println(Thread.currentThread().getName());
    }, Executors.newFixedThreadPool(10));

    
    System.out.println("END OF PROGRAM");
}

}

结果是：

END OF PROGRAM

如果我提供了ExecutorService，JVM应该等待CompletableFuture完成(.thenAceptAsync部分)，但是程序马上就完成了。

也许我的心态是错的。有人能给我解释一下吗？

java

multithreading

asynchronous

回答 1

Stack Overflow用户

发布于 2022-01-02 19:31:36

程序在请求完成之前退出。请求是使用sendAsync异步执行的，因此它不会阻止程序的执行。

要阻止执行并等待API响应，您必须使用response.get();，如下所示：

public static void main(String[] args) throws URISyntaxException, ExecutionException,
     InterruptedException {
final String URL = "https://jsonplaceholder.typicode.com/users/1";
    
HttpRequest request = HttpRequest.newBuilder(new URI(URL)).GET().timeout(Duration.of(10, ChronoUnit.SECONDS)).build();
    
CompletableFuture<Void> response = HttpClient.newHttpClient()
                    .sendAsync(request, HttpResponse.BodyHandlers.ofString())
                    .thenAcceptAsync(r -> {
                System.out.println(r.statusCode());
                System.out.println(Thread.currentThread().getName());
}, Executors.newFixedThreadPool(10));
    
 response.get();//wait for API response
 System.out.println("END OF PROGRAM");
}

输出：

200
pool-1-thread-1
END OF PROGRAM

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/70557933

复制

相似问题

问CompletableFuture thenAccept不工作
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问CompletableFuture thenAccept不工作EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问CompletableFuture thenAccept不工作
EN