// Java异步调用方法示例
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AsyncExample {
// 模拟一个耗时任务
public static String longRunningTask() throws InterruptedException {
Thread.sleep(2000); // 模拟耗时操作
return "任务完成";
}
// 异步调用方法
public static CompletableFuture<String> asyncCall() {
return CompletableFuture.supplyAsync(() -> {
try {
return longRunningTask();
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
});
}
public static void main(String[] args) {
// 调用异步方法
CompletableFuture<String> future = asyncCall();
// 可以在这里执行其他操作,不会阻塞主线程
System.out.println("正在等待异步任务完成...");
// 获取异步任务的结果(会阻塞直到结果返回)
try {
String result = future.get();
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
}
Thread.sleep(2000) 来模拟 2 秒的延迟。CompletableFuture.supplyAsync 来异步执行 longRunningTask。supplyAsync 会在后台线程池中执行传入的 lambda 表达式,并返回一个 CompletableFuture 对象。asyncCall 并获取 CompletableFuture 对象。然后可以继续执行其他操作,不会阻塞主线程。最后通过 future.get() 阻塞并等待异步任务的结果。这种方式可以有效避免阻塞主线程,提高程序的并发性能。
下一篇:java set 遍历
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站