Blog

Java Future 使用案例 - Teiid 中 Future 的使用

Posted by Kylin Soong on Dec 8, 2015 categorized as java

在 Java Future FutureTask 示例 我们描述了 Future 接口以及 FutureTask 类，Future 接口是程序有异步化的功能，它提供了三种主要功能：

  • 判断任务是否完成,
  • 能够中断任务,
  • 能够获取任务执行结果.

本文给出一些 Teiid 代码 中 Java Future 的使用的案例.

案例一: ResultsFuture

ResultsFuture 它实现了 java.util.concurrent.Future 接口，它有一个 ResultsReceiver 属性，和 LinkedList<CompletionListener> 属性， UML 图如下：

UML of FutureTask

完整ResultsFuture实现代码, 概括如下:

  1. 对 java.util.concurrent.Future 接口中 cancel(boolean mayInterruptIfRunning), isCancelled() 简单实现，即对 ResultsFuture 不取消。
  2. ResultsReceiver 提供了一个对外的接口，用来设定 result, done, exception
  3. ResultsFuture 可以添加 listeners, 当 ResultsFuture get 返回后，所有 listeners 都会执行.

SocketServerInstanceImpl 的 read() 方法

如下为 SocketServerInstanceImpl 的 read() 方法，使用 Feature 的方法异步调运远程的方法实现

Java Future Teiid