示例工程教程【免费下载链接】java-design-patternsDesign patterns implemented in Java项目地址https://gitcode.com/GitHub_Trending/ja/java-design-patterns点击查看免费下载本篇文章以 java-design-patterns 仓库中的 async-method-invocation 模块为核心系统讲解异步方法调用Asynchronous Method InvocationAMI设计模式从模式意图、三大核心接口到ThreadAsyncExecutor的线程级实现与内部状态机再到可运行的火箭发射示例与测试验证帮助读者理解如何让调用线程不阻塞地并行执行多个独立任务并通过回调Callback或阻塞等待两种方式回收结果。读完本文你将能基于仓库源码复现该模式并掌握它与FutureTask、CompletableFuture、ExecutorService等 Java 标准库异步设施的关系。模式的意图与背景异步方法调用AMI又称异步方法调用模式Asynchronous Procedure Call是一种并发设计模式。其核心思想是调用发起方调用线程在发起任务后立即返回不必阻塞等待任务执行完毕任务在独立的线程中并行执行执行结果通过回调Callback或稍后的显式等待等待/轮询返回给调用方。根据多线程编程的经典定义在调用方等待被调用代码执行完毕期间调用点不会被阻塞相反当应答到达时调用线程会得到通知。轮询Polling获取应答是一种不可取的做法——这正是本模式要避免的。用日常场景来类比发射太空火箭时任务指挥官下达发射命令后并不会原地干等火箭升空而是在一段时间之后才得知火箭成功发射或发射失败。这正对应异步方法调用发起后立即返回、结果稍后送达的行为。在 java-design-patterns 仓库中该模式位于 async-method-invocation 模块归类于并发Concurrency类别标签包含异步Asynchronous、解耦Decoupling、响应式Reactive、可扩展性Scalability、线程管理Thread management。模式的三块核心拼图本模式由三个关键抽象组成它们分别承担结果容器完成通知和任务调度三种职责对应源码中的三个接口文件1. AsyncResult —— 异步结果容器AsyncResultT是异步求值结果的中间容器定义在 AsyncResult.javapublic interface AsyncResultT { boolean isCompleted(); T getValue() throws ExecutionException; void await() throws InterruptedException; }三个方法各司其职isCompleted()返回任务执行是否已经结束成功完成或失败都算结束getValue()获取任务求值结果若执行失败则抛出包装了根因的ExecutionException若任务尚未完成则抛出IllegalStateExceptionawait()阻塞当前线程直到任务完成若线程被中断则抛出InterruptedException。从接口语义可以看出AsyncResult类似于 Java 标准库中Future的简化版——它代表一个将来才可能可用的值。2. AsyncCallback —— 完成回调AsyncCallbackT定义在 AsyncCallback.javapublic interface AsyncCallbackT { void onComplete(T value); void onError(Exception ex); }它提供了两个处理方法任务成功完成时回调onComplete(value)携带求值结果任务执行失败时回调onError(ex)携带异常对象非空。通过提供回调调用方无需主动等待任务一旦完成便能在执行线程中立即获得通知。3. AsyncExecutor —— 异步执行器AsyncExecutor定义在 AsyncExecutor.java负责管理异步任务的调度与结果回收public interface AsyncExecutor { T AsyncResultT startProcess(CallableT task); T AsyncResultT startProcess(CallableT task, AsyncCallbackT callback); T T endProcess(AsyncResultT asyncResult) throws ExecutionException, InterruptedException; }startProcess(CallableT task)启动一个异步任务立即返回AsyncResult不阻塞调用线程startProcess(CallableT task, AsyncCallbackT callback)重载版本任务完成时会额外执行回调endProcess(AsyncResultT asyncResult)结束一个异步任务——若任务尚未完成则阻塞等待然后返回求值结果任务失败时抛出ExecutionException线程被中断时抛出InterruptedException。深入源码ThreadAsyncExecutor 的实现机制ThreadAsyncExecutor是AsyncExecutor的标准实现位于 ThreadAsyncExecutor.java。它的实现策略很直白每个任务启动一个新线程执行。启动流程startProcesspublic T AsyncResultT startProcess(CallableT task, AsyncCallbackT callback) { var result new CompletableResult(callback); new Thread( () - { try { result.setValue(task.call()); } catch (Exception ex) { result.setException(ex); } }, executor- idx.incrementAndGet()) .start(); return result; }关键细节每次调用都会创建一个CompletableResult实例作为结果容器然后新建一个名为executor-1、executor-2……的线程去执行任务线程命名序号来自AtomicInteger idx计数器保证并发环境下序号递增的线程安全性任务成功则调用result.setValue(task.call())任务抛出任何异常包括NullPointerException都会被捕获并调用result.setException(ex)startProcess立即返回调用线程完全不被阻塞。内部状态机CompletableResultCompletableResultT是ThreadAsyncExecutor的私有静态内部类实现了AsyncResult接口。它用volatile int state维护三态状态机源码注释明确说明它是FutureTask和CompletableFuture的极简简化版static final int RUNNING 1; static final int FAILED 2; static final int COMPLETED 3;RUNNING任务执行中。isCompleted()返回state RUNNING即只有 FAILED 或 COMPLETED 才算结束COMPLETED任务成功。setValue写入结果、置状态为 COMPLETED若有回调则立即执行callback.onComplete(value)随后通过synchronized(lock) { lock.notifyAll(); }唤醒所有等待线程FAILED任务失败。setException记录异常、置状态为 FAILED若有回调则执行callback.onError(exception)同样通知所有等待线程。getValue()的分支逻辑与状态严格对应public T getValue() throws ExecutionException { if (state COMPLETED) { return value; } else if (state FAILED) { throw new ExecutionException(exception); } else { throw new IllegalStateException(Execution not completed yet); } }await()则利用内置锁对象lock实现经典的等待-通知模型在while (!isCompleted())循环中调用lock.wait()挂起当前线程直到setValue/setException唤醒它——这保证了即使被虚假唤醒也能重新检查完成状态public void await() throws InterruptedException { synchronized (lock) { while (!isCompleted()) { lock.wait(); } } }结果回收endProcessendProcess是阻塞等待方式的入口若结果尚未完成则先调用await()阻塞然后返回getValue()的结果。测试代码也验证了它可重复调用且幂等——任务完成后再次调用仍返回同一结果。可运行示例发射太空火箭与部署月球车模块的演示入口是 App.javamain方法完整展示了异步调用模式的使用流程public static void main(String[] args) throws Exception { // 构造一个执行异步任务的执行器 var executor new ThreadAsyncExecutor(); // 启动多个处理时长不同的异步任务最后两个携带回调处理器 final var asyncResult1 executor.startProcess(lazyval(10, 500)); final var asyncResult2 executor.startProcess(lazyval(test, 300)); final var asyncResult3 executor.startProcess(lazyval(50L, 700)); final var asyncResult4 executor.startProcess(lazyval(20, 400), callback(Deploying lunar rover)); final var asyncResult5 executor.startProcess(lazyval(callback, 600), callback(Deploying lunar rover)); // 模拟当前线程继续自己的工作异步任务则在各自线程中执行 Thread.sleep(350); // 我们正在努力工作中 log(Mission command is sipping coffee); // 等待任务完成 final var result1 executor.endProcess(asyncResult1); final var result2 executor.endProcess(asyncResult2); final var result3 executor.endProcess(asyncResult3); asyncResult4.await(); asyncResult5.await(); // 记录任务结果回调在完成时立即记录 log(String.format(ROCKET_LAUNCH_LOG_PATTERN, result1)); log(String.format(ROCKET_LAUNCH_LOG_PATTERN, result2)); log(String.format(ROCKET_LAUNCH_LOG_PATTERN, result3)); }示例中两个辅助方法值得说明lazyval(T value, long delayMillis)生成一个延迟求值的Callable先Thread.sleep模拟任务耗时再记录火箭成功发射日志并返回结果值。五个任务分别延迟 500ms、300ms、700ms、400ms、600ms模拟不同耗时callback(String name)生成一个匿名AsyncCallback任务完成时在工作线程内记录日志如Deploying lunar rover 20失败时记录错误信息。注意一个值得强调的线程模型差异App.java 的类注释中明确指出异步结果由主线程统一回收而回调在工作线程内立即执行。这在后续迁移到线程池时必须留意——回调可能运行在线程池的任意工作线程上。程序控制台输出解析运行App的典型输出如下线程名前缀清晰可见21:47:08.227 [executor-2] INFO com.iluwatar.async.method.invocation.App - Space rocket test launched successfully 21:47:08.269 [main] INFO com.iluwatar.async.method.invocation.App - Mission command is sipping coffee 21:47:08.318 [executor-4] INFO com.iluwatar.async.method.invocation.App - Space rocket 20 launched successfully 21:47:08.335 [executor-4] INFO com.iluwatar.async.method.invocation.App - Deploying lunar rover 20 21:47:08.414 [executor-1] INFO com.iluwatar.async.method.invocation.App - Space rocket 10 launched successfully 21:47:08.519 [executor-5] INFO com.iluwatar.async.method.invocation.App - Space rocket callback launched successfully 21:47:08.519 [executor-5] INFO com.iluwatar.async.method.invocation.App - Deploying lunar rover callback 21:47:08.616 [executor-3] INFO com.iluwatar.async.method.invocation.App - Space rocket 50 launched successfully 21:47:08.617 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket 10 launch complete 21:47:08.617 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket test launch complete 21:47:08.618 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket 50 launch complete观察要点五个任务的发射成功日志分别来自executor-1到executor-5证明五个任务确实并行执行于独立线程带回调的任务20 和 callback其回调日志紧跟发射成功日志之后、且同样打印在 executor 线程上证明回调在工作线程内立即触发主线程在 350ms 时打印任务指挥在喝咖啡说明主线程在任务执行期间并未阻塞而是继续干自己的事主线程最后通过endProcess和await()统一回收三个无回调任务的结果按完成顺序打印发射完成。类图结构该模块的类图位于 async-method-invocation/etc/async-method-invocation.png展示了AsyncExecutor、AsyncResult、AsyncCallback三个接口与ThreadAsyncExecutor含内部类CompletableResult之间的依赖与实现关系Async Method Invocation 模式的类图展示 AsyncExecutor、AsyncResult、AsyncCallback 接口与 ThreadAsyncExecutor 实现的关系适用场景根据模式文档在以下情况应当使用异步方法调用模式有多个相互独立的任务需要并行执行需要提升一组顺序执行任务的整体性能通过并行化缩短总耗时处理能力有限或任务执行时间较长且调用方不应等待任务就绪发起调用后立即返回让任务在后台运行。更具体的落地场景包括耗时或资源密集型的操作IO、网络请求、复杂计算不应以同步方式阻塞调用方GUI 应用中避免长时间任务导致界面冻结或无响应Web 应用中实现非阻塞 IO以及微服务架构中通过消息队列或事件流进行异步通信。与 Java 标准库异步设施的关系App.java 的类注释明确指出Java 标准库已经提供了本模式的成熟实现包括java.util.concurrent.FutureTask、java.util.concurrent.CompletableFuture与java.util.concurrent.ExecutorService。仓库示例没有覆盖并行编程的所有场景而是提供一个帮助理解模式本质的简化版本FutureTask可视为AsyncResult的完整版堂兄弟同样支持查询完成状态、阻塞获取结果CompletableFuture在 Future 基础上补充了回调链对应AsyncCallback的更强大形式支持组合式异步编排ExecutorService提供了线程池化的任务执行与调度能力对应AsyncExecutor的职责但通过复用线程避免每任务建线程的开销微软的基于任务的异步模式Task-based Asynchronous Pattern也是这一思想的工业级实践。与相关设计模式的关系异步方法调用模式常与以下模式协同工作Command 模式异步方法调用可用于实现命令模式将命令对象作为任务异步执行实现请求的封装与解耦Observer 模式当被观察对象状态变化时可异步地通知观察者避免通知逻辑阻塞主体线程Promise 模式AsyncResult接口本质上就是一种 Promise——它代表一个当前可能尚未就绪的值这正是 Promise 模式的核心理念仓库中另有独立的 promise 模块可对照学习。收益与代价采用该模式的收益响应性提升主线程或应用主流程保持不阻塞GUI 应用的用户体验与整体响应速度得到改善资源利用率更高通过并行执行更充分地利用 CPU 与 IO 资源提升应用吞吐量可扩展性增强任务可更有效地分发到可用资源上应用更容易水平扩展。相应的代价与风险复杂度上升异步化会让代码更难理解、调试与维护资源管理压力需要谨慎管理线程或执行上下文可能引入额外开销甚至线程资源耗尽问题错误处理变复杂异常可能发生在不同线程或不同时间点错误传播路径不再直观。仓库实现本身也印证了这一点ThreadAsyncExecutor为每个任务新建线程这种每任务一线程策略在任务量很大时会带来线程创建开销与资源压力生产环境更推荐切换到线程池方案。测试验证与运行方式模块包含两组测试可作为模式正确性的权威验证ThreadAsyncExecutorTest.java使用 JUnit 5 与 Mockito覆盖了六个典型场景成功任务无/有回调验证onComplete被调用一次、onError不被调用、返回值与预期对象相同长耗时任务无/有回调验证完成前getValue()抛出IllegalStateException完成后结果一致endProcess阻塞等待与重复调用的幂等性空任务null task无/有/空回调验证抛出以NullPointerException为根因的ExecutionException且回调走onError分支AppTest.java验证App主程序可正常执行。运行示例在仓库根目录执行./mvnw -pl async-method-invocation test可运行测试./mvnw -pl async-method-invocation exec:java或直接运行com.iluwatar.async.method.invocation.Apppom.xml 中已配置该主类即可观察并行发射火箭的完整输出。模块依赖 slf4j-api 与 logback-classic 提供日志输出测试依赖 junit-jupiter-engine 与 mockito-core均已在 pom.xml 中声明。小结异步方法调用模式用发起即返回、结果后达的方式解耦了任务提交与结果消费AsyncResult充当结果容器AsyncCallback提供完成通知AsyncExecutor负责调度。通过 java-design-patterns 仓库的ThreadAsyncExecutor实现我们可以直观看到线程创建、状态机流转、等待-通知机制与回调触发的完整链路。理解这个最小实现再对照FutureTask、CompletableFuture、ExecutorService等标准库设施便能透彻掌握 Java 异步编程从每任务一线程到线程池 回调链的演进脉络。赞分享示例工程教程【免费下载链接】java-design-patternsDesign patterns implemented in Java项目地址https://gitcode.com/GitHub_Trending/ja/java-design-patterns点击查看免费下载相关推荐Java 异步方法调用Async Method Invocation模式详解基于 java-design-patterns 的源码级剖析Java 异步方法调用Async Method Invocation模式详解基于 java design patterns 的源码级剖析 异步方法调用A示例工程教程Java 设计模式实战Async Method Invocation 异步方法调用模式在 java-design-patterns 中的实现Java 设计模式实战Async Method Invocation 异步方法调用模式在 java design patterns 中的实现 异步方法调用A示例工程教程Active Object 模式实战基于 java-design-patterns 的 Java 异步方法调用与调度机制详解Active Object 模式实战基于 java design patterns 的 Java 异步方法调用与调度机制详解 本文以 java design示例工程教程上一篇Hetty Scope API编程方式管理规则下一篇MAVSDK高级开发深入理解MAVLink协议与数据交互的终极指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考