【设计模式】JAVA Design Patterns——Async Method Invocation(异步方法调用模式)

简介: 【设计模式】JAVA Design Patterns——Async Method Invocation(异步方法调用模式)

🔍目的


异步方法调用是一个调用线程 在等待任务结果时不会阻塞的模式,模式为多个独立的任务提供并行的处理方式并且通过回调或等到它们全部完成来接受任务结果


🔍解释


真实世界例子

发射火箭是一项令人激动的事务。任务指挥官发出了发射命令,经过一段不确定的时间后,火箭要么成功发射,要么惨遭失败。


通俗描述

异步方法调用开始任务处理,并在任务完成之前立即返回。 任务处理的结果稍后返回给调用方。


维基百科

多线程计算机编程中,异步方法调用(AMI),也称为异步方法调用或异步模式,是一种设计模式,其中在等待被调用的代码完成时不会阻塞调用站点。 而是在执行结果到达时通知调用线程。轮询调用结果是不希望的选项


程序示例

假如我们正在发生太空火箭并部署月球漫游车。就可以演示异步调用模式。

模式的关键部分是AsyncResult(用于异步评估值的中间容器),AsyncCallback(可以在任务完成时被执行)和AsyncExecutor(用于管理异步任务的执行)。


创建异步评估的中间容器

public interface AsyncResult<T> {
  boolean isCompleted();
  T getValue() throws ExecutionException;
  void await() throws InterruptedException;
}


创建异步回调执行操作的类

public interface AsyncCallback<T> {
  void onComplete(T value, Optional<Exception> ex);
}


创建异步任务的执行器接口

public interface AsyncExecutor {
  <T> AsyncResult<T> startProcess(Callable<T> task);
  <T> AsyncResult<T> startProcess(Callable<T> task, AsyncCallback<T> callback);
  <T> T endProcess(AsyncResult<T> asyncResult) throws ExecutionException, InterruptedException;
}


创建异步任务执行器的实现类

public class ThreadAsyncExecutor implements AsyncExecutor {
 
  @Override
  public <T> AsyncResult<T> startProcess(Callable<T> task) {
    return startProcess(task, null);
  }
 
  @Override
  public <T> AsyncResult<T> startProcess(Callable<T> task, AsyncCallback<T> 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;
  }
 
  @Override
  public <T> T endProcess(AsyncResult<T> asyncResult)
      throws ExecutionException, InterruptedException {
    if (!asyncResult.isCompleted()) {
      asyncResult.await();
    }
    return asyncResult.getValue();
  }
}


现在我们准备发射一个火箭

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 the results of the tasks, callbacks log immediately when complete
  // 记录任务结果的日志, 回调的日志会在回调完成时立刻记录
  log("Space rocket <" + result1 + "> launch complete");
  log("Space rocket <" + result2 + "> launch complete");
  log("Space rocket <" + result3 + "> launch complete");
}


在控制台中查看其执行内容

14:32:01.227 [executor-2] INFO com.iluwatar.async.method.invocation.App - Space rocket <test> launched successfully
14:32:01.269 [main] INFO com.iluwatar.async.method.invocation.App - Mission command is sipping coffee
14:32:01.318 [executor-4] INFO com.iluwatar.async.method.invocation.App - Space rocket <20> launched successfully
14:32:01.335 [executor-4] INFO com.iluwatar.async.method.invocation.App - Deploying lunar rover <20>
14:32:01.414 [executor-1] INFO com.iluwatar.async.method.invocation.App - Space rocket <10> launched successfully
14:32:01.519 [executor-5] INFO com.iluwatar.async.method.invocation.App - Space rocket <callback> launched successfully
14:32:01.519 [executor-5] INFO com.iluwatar.async.method.invocation.App - Deploying lunar rover <callback>
14:32:01.616 [executor-3] INFO com.iluwatar.async.method.invocation.App - Space rocket <50> launched successfully
14:32:01.617 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket <10> launch complete
14:32:01.617 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket <test> launch complete
14:32:01.618 [main] INFO com.iluwatar.async.method.invocation.App - Space rocket <50> launch complete


🔍类图


0a683a20c9d24577981c45977bc96051.png


🔍适用场景

在以下情况下使用异步方法调用模式

  • 您有多个可以并行运行的独立任务
  • 您需要提高一组顺序任务的性能
  • 您的处理能力或长时间运行的任务数量有限,并且调用方不应等待任务执行完毕

6e583dcee109441aab138b616db665dd.gif

相关文章
|
17天前
|
设计模式 Java 数据库连接
【重温设计模式】代理模式及其Java示例
【重温设计模式】代理模式及其Java示例
|
2天前
|
监控 网络协议 Java
Java一分钟之-Netty:高性能异步网络库
【6月更文挑战第11天】Netty是Java的高性能异步网络框架,基于NIO,以其高吞吐量、低延迟、灵活性和安全性受到青睐。常见问题包括内存泄漏、ChannelHandler滥用和异常处理不当。要规避这些问题,需正确释放ByteBuf,精简ChannelPipeline,妥善处理异常,并深入理解Netty原理。通过代码审查、遵循最佳实践和监控日志,可提升代码质量和性能。掌握Netty,打造高效网络服务。
9 2
|
14天前
|
设计模式 存储 前端开发
Java的mvc设计模式在web开发中应用
Java的mvc设计模式在web开发中应用
|
17天前
|
设计模式 安全 Java
【设计模式】JAVA Design Patterns——Curiously Recurring Template Pattern(奇异递归模板模式)
该文介绍了一种C++的编程技巧——奇异递归模板模式(CRTP),旨在让派生组件能继承基本组件的特定功能。通过示例展示了如何创建一个`Fighter`接口和`MmaFighter`类,其中`MmaFighter`及其子类如`MmaBantamweightFighter`和`MmaHeavyweightFighter`强制类型安全,确保相同重量级的拳手之间才能进行比赛。这种设计避免了不同重量级拳手间的错误匹配,编译时会报错。CRTP适用于处理类型冲突、参数化类方法和限制方法只对相同类型实例生效的情况。
【设计模式】JAVA Design Patterns——Curiously Recurring Template Pattern(奇异递归模板模式)
|
19天前
|
设计模式 Java 数据库
【设计模式】JAVA Design Patterns——Converter(转换器模式)
转换器模式旨在实现不同类型间的双向转换,减少样板代码。它通过通用的Converter类和特定的转换器(如UserConverter)简化实例映射。Converter类包含两个Function对象,用于不同类型的转换,同时提供列表转换方法。当需要在逻辑上对应的类型间转换,或处理DTO、DO时,此模式尤为适用。
【设计模式】JAVA Design Patterns——Converter(转换器模式)
|
20天前
|
设计模式 安全 Java
Java设计模式
Java设计模式
6 1
|
8月前
|
设计模式 安全 Java
JAVA设计模式1:单例模式,确保每个类只能有一个实例
JAVA设计模式1:单例模式,确保每个类只能有一个实例
|
8月前
|
设计模式 存储 安全
【设计模式——学习笔记】23种设计模式——单例模式Singleton(原理讲解+应用场景介绍+案例介绍+Java代码实现)
【设计模式——学习笔记】23种设计模式——单例模式Singleton(原理讲解+应用场景介绍+案例介绍+Java代码实现)
27 0
|
29天前
|
设计模式 安全 Java
【JAVA】Java 中什么叫单例设计模式?请用 Java 写出线程安全的单例模式
【JAVA】Java 中什么叫单例设计模式?请用 Java 写出线程安全的单例模式
|
28天前
|
设计模式 SQL 安全
Java一分钟之-设计模式:单例模式的实现
【5月更文挑战第16天】本文介绍了单例模式的四种实现方式:饿汉式(静态初始化)、懒汉式(双检锁)、静态内部类和枚举单例,以及相关问题和解决方法。关注线程安全、反射攻击、序列化、生命周期和测试性,选择合适的实现方式以确保代码质量。了解单例模式的优缺点,谨慎使用,提升设计效率。
31 3