// 使用 Java 的 CompletableFuture 实现异步编程
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AsyncExample {
public static void main(String[] args) {
// 创建一个异步任务,模拟耗时操作
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(2000); // 模拟耗时操作
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Hello, World!";
});
// 当异步任务完成时执行回调
future.thenAccept(result -> System.out.println("异步任务结果: " + result));
// 防止主线程过早退出
try {
future.get(); // 等待异步任务完成
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
}
CompletableFuture 对象。这个方法接受一个 Supplier 函数式接口作为参数,表示异步任务的逻辑。这段代码展示了如何使用 CompletableFuture 来执行一个异步任务,并在任务完成后打印结果。
下一篇:java service
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站