Java CompletableFuture 中怎么同步执行-java教程-PHP中文网

如何同步执行 CompletableFuture

使用 get() 方法可以阻塞当前线程，直到 completablefuture 完成并获取结果。调用该方法会抛出 interruptedexception 和 executionexception，需进行捕获处理。

Java CompletableFuture 中怎么同步执行

import java.util.concurrent.CompletableFuture;

public class SyncExample {
    public static void main(String[] args) {
        CompletableFuture<string> future = CompletableFuture.supplyAsync(() -> "Hello");
        try {
            String result = future.get(); // 阻塞等待
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}</string>

如何处理异步任务中的异常

在 get() 调用中，如果异步任务抛出异常，会被包装在 ExecutionException 中。可以通过 getCause() 获取原始异常。

Java CompletableFuture 中怎么同步执行

JavaScript 开发专家

掌握包含 ES6+、异步模式和 Node.js API 的现代 JavaScript。处理 Promise、事件循环和浏览器/Node 兼容性。在 JavaSc

下载

import java.util.concurrent.CompletableFuture;

public class ExceptionExample {
    public static void main(String[] args) {
        CompletableFuture<string> future = CompletableFuture.supplyAsync(() -> {
            throw new RuntimeException("Error");
        });
        try {
            future.get();
        } catch (Exception e) {
            if (e instanceof ExecutionException) {
                System.out.println(e.getCause().getMessage());
            }
        }
    }
}</string>

如何设置超时时间

可以使用 get(long timeout, TimeUnit unit) 方法设置超时时间。如果在规定时间内未完成，将抛出 TimeoutException。

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;

public class TimeoutExample {
    public static void main(String[] args) {
        CompletableFuture<string> future = CompletableFuture.supplyAsync(() -> {
            try { Thread.sleep(5000); } catch (InterruptedException e) {}
            return "Done";
        });
        try {
            String result = future.get(2, TimeUnit.SECONDS);
            System.out.println(result);
        } catch (Exception e) {
            System.out.println("Timeout or Error");
        }
    }
}</string>