当前位置：首页 > Java

java如何异步等待

2026-03-24 00:08:52Java

异步等待的实现方法

在Java中实现异步等待可以通过多种方式完成，主要包括使用CompletableFuture、线程池、回调函数等。以下是几种常见的实现方法。

使用CompletableFuture

CompletableFuture是Java 8引入的异步编程工具，支持链式调用和组合操作。通过thenApply、thenAccept等方法可以实现异步任务的串联和等待。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    // 模拟耗时操作
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return "任务完成";
});

future.thenAccept(result -> System.out.println(result));

使用Future和ExecutorService

通过ExecutorService提交任务并返回Future对象，可以检查任务是否完成或阻塞等待结果。

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(() -> {
    Thread.sleep(1000);
    return "任务结果";
});

// 阻塞等待结果
String result = future.get();
System.out.println(result);
executor.shutdown();

使用CountDownLatch

CountDownLatch是一种同步辅助工具，可以让一个或多个线程等待其他线程完成操作。

CountDownLatch latch = new CountDownLatch(1);

new Thread(() -> {
    try {
        Thread.sleep(1000);
        System.out.println("子线程完成");
        latch.countDown();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 主线程等待
latch.await();
System.out.println("主线程继续执行");

使用回调函数

通过定义回调接口，可以在异步任务完成后触发回调逻辑。

interface Callback {
    void onComplete(String result);
}

void doAsyncTask(Callback callback) {
    new Thread(() -> {
        try {
            Thread.sleep(1000);
            callback.onComplete("回调结果");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }).start();
}

// 调用异步任务
doAsyncTask(result -> System.out.println(result));

使用Reactive编程（如RxJava）

响应式编程框架如RxJava提供了更强大的异步处理能力，支持事件流和背压控制。

Observable.fromCallable(() -> {
    Thread.sleep(1000);
    return "RxJava结果";
}).subscribeOn(Schedulers.io())
  .observeOn(Schedulers.single())
  .subscribe(result -> System.out.println(result));