异步编程的 7 种实现方式

2023-07-14

java

1. 线程 (Thread)

Java 的 Thread 类允许创建并启动线程来执行异步任务。线程是最基础的异步编程方式，但需要手动管理线程生命周期。

优点：直接操作系统线程，适合简单的异步任务。
缺点：线程创建开销大，过多线程影响性能和资源消耗。

Thread thread = new Thread(() -> {
    System.out.println("异步任务开始");
});
thread.start();

2. Runnable 和 Callable

Runnable 和 Callable 是两种接口，用于定义异步任务。Runnable 没有返回值，而 Callable 可以返回结果或抛出异常。

优点：可与线程池配合使用，简化线程管理。
缺点：需要手动管理线程，代码复杂度较高。

Callable<Integer> task = () -> {
    Thread.sleep(1000);
    return 42;
};
Future<Integer> result = Executors.newSingleThreadExecutor().submit(task);

3. Future 和 ExecutorService

Future 代表异步操作的结果，可与 ExecutorService 搭配使用，便于管理和控制线程池。通过 get() 方法获取任务结果。

优点：提供异步结果和超时控制。
缺点：Future 不支持链式调用，取消任务后仍需手动处理资源。

ExecutorService executor = Executors.newCachedThreadPool();
Future<Integer> future = executor.submit(() -> {
    Thread.sleep(1000);
    return 42;
});
Integer result = future.get();

4. CompletableFuture

CompletableFuture 是 Java 8 引入的类，支持链式调用和非阻塞获取结果，适合复杂的异步流操作。

优点：支持链式调用和组合操作，功能强大。
缺点：异常处理较复杂，易导致回调地狱。

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    return 42;
}).thenApply(result -> result + 1);

future.thenAccept(System.out::println);

5. Fork/Join 框架

Fork/Join 是 Java 7 引入的框架，适合处理大任务的分治问题，递归分解任务，使用工作窃取算法优化线程池性能。

优点：适合并行计算，充分利用多核 CPU。
缺点：适合 CPU 密集型任务，代码复杂度较高。

ForkJoinPool forkJoinPool = new ForkJoinPool();
RecursiveTask<Integer> task = new RecursiveTask<>() {
    @Override
    protected Integer compute() {
        return 42; // 递归任务的计算逻辑
    }
};
Integer result = forkJoinPool.invoke(task);

6. Reactor 异步框架

Reactor 是响应式编程框架，基于非阻塞和事件驱动模型实现异步操作，适合高并发 I/O 场景。

优点：支持背压，非阻塞模型。
缺点：需要对响应式编程有一定理解，学习成本较高。

1 2	Mono<Integer> mono = Mono.fromSupplier(() -> 42); mono.subscribe(System.out::println);

7. Spring 异步支持 (@Async)

Spring 框架提供 @Async 注解支持异步方法执行，可在 Spring 应用中快速实现异步调用。

优点：简单易用，适合 Spring 应用。
缺点：依赖 Spring 框架，需要配置线程池。

@Async
public void asyncMethod() {
    System.out.println("异步方法执行中");
}

总结

实现方式	适用场景	优点	缺点
Thread	简单异步任务	直接操作系统线程	线程管理复杂，性能开销较高
Runnable/Callable	简单异步任务	与线程池配合使用	手动管理线程
Future	有结果的异步任务	提供超时控制	不支持链式调用，资源管理复杂
CompletableFuture	多步骤异步任务	支持链式调用	异常处理复杂
Fork/Join	并行计算	充分利用多核 CPU	适合 CPU 密集型任务
Reactor	高并发 I/O	非阻塞模型，支持背压	学习成本较高
Spring @Async	Spring 异步方法	简单易用	依赖 Spring 框架

< Redis 的大 Key 对持久化有什么影响？

异步编程的 7 种实现方式 >