本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 了解 Java 中的 AWS Flow Framework 任务
了解任务

**Topics**
+ [

## Task
](#details.task)
+ [

## 执行顺序
](#details.order)
+ [

## 工作流程执行
](#details.workflow)
+ [

## 不确定性
](#details.non)

## Task


for Java AWS Flow Framework 用来管理异步代码执行的底层原语是`Task`类。`Task` 类型的对象表示必须异步执行的工作。在您调用异步方法时，框架会创建 `Task` 来执行该方法中的代码并将其放在列表中以稍后执行。同样地，在您调用 `Activity` 时，会为它创建 `Task`。方法调用在此之后返回，通常返回 `Promise<T>` 作为调用的未来结果。

`Task` 类是公有的，可以直接使用。例如，我们可以重写 Hello World 示例来使用 `Task` 代替异步方法。

```
@Override
public void startHelloWorld(){
       final Promise<String> greeting = client.getName();
        new Task(greeting) {
        @Override
        protected void doExecute() throws Throwable {
        	client.printGreeting("Hello " + greeting.get() +"!");
        }
    };
}
```

框架在传递给 `Task` 的构造函数的所有 `Promise` 都已准备就绪后调用 `doExecute()` 方法。有关该`Task`类的更多详细信息，请参阅 适用于 Java 的 AWS SDK 文档。

框架还包括一个名为 `Functor` 的类，它表示也是 `Promise<T>` 的 `Task`。`Functor` 对象在 `Task` 完成后变为就绪状态。在以下示例中，创建了 `Functor` 来获取问候语：

```
Promise<String> greeting = new Functor<String>() {
    @Override
    protected Promise<String> doExecute() throws Throwable {
        return client.getGreeting();
    }
};
client.printGreeting(greeting);
```

## 执行顺序


仅当传递给对应异步方法或活动的所有 `Promise<T>` 类型化参数都已准备就绪后，任务才可执行。已准备好执行的 `Task` 在逻辑上移动到就绪队列。换言之，将安排它执行。工作线程类执行任务的方法是调用您在异步方法的正文中编写的代码，或在 Amazon Simple Workflow Service AWS(AWS) 中安排活动任务（对于活动方法）。

在任务执行并生成结果后，它们引发其他任务变为就绪状态，从而使程序继续执行。框架执行任务的方式对了解异步代码的执行顺序非常重要。程序中按顺序显示的代码实际上可能不按该顺序执行。

```
Promise<String> name = getUserName();
printHelloName(name);
printHelloWorld();
System.out.println("Hello, Amazon!");

@Asynchronous
private Promise<String> getUserName(){
	return Promise.asPromise("Bob");
}
@Asynchronous
private void printHelloName(Promise<String> name){
	System.out.println("Hello, " + name.get() + "!");
}
@Asynchronous
private void printHelloWorld(){
	System.out.println("Hello, World!");
}
```

以上列表中的代码将输出以下内容：

```
Hello, Amazon!
Hello, World!
Hello, Bob
```

这可能与您的预期不同，但通过思考异步方法的任务的执行方式，可以轻松地进行解释：

1. 对 `getUserName` 的调用会创建 `Task`。我们将它称为 `Task1`。因为`getUserName`不接受任何参数，`Task1`所以会立即进入就绪队列。

1. 接下来，对 `printHelloName` 的调用会创建需要等待 `getUserName` 的结果的 `Task`。我们将它称为 `Task2`。由于必需的值尚未准备就绪，`Task2`因此已列入等候名单。

1. 然后创建 ` printHelloWorld` 的任务并将其添加到就绪队列。我们将它称为 `Task3`。

1. 之后 `println` 语句会将“Hello, Amazon\$1”输出到 控制台。

1. 此时，`Task1` 和 `Task3` 在就绪队列中，`Task2` 在等待列表中。

1. 工作程序执行 `Task1`，其结果使 `Task2` 就绪。`Task2` 在 `Task3` 之后添加到就绪队列。

1. 然后，`Task3` 和 `Task2` 按该顺序执行。

活动的执行采取相同的模式。在活动客户端上调用方法时会创建一个 `Task`，任务执行后会在 Amazon SWF 中安排一个活动。

框架依赖代码生成和动态代理等功能来在您的程序中注入将方法调用转换为活动调用和异步任务的逻辑。

## 工作流程执行


工作流实现的执行也由工作线程类管理。在工作流客户端上调用方法时，它会调用 Amazon SWF 来创建工作流实例。Amazon SWF 中的任务不应与框架中的任务混淆。Amazon SWF 中的任务是活动任务或决策任务。活动任务的执行很简单。活动工作线程类从 Amazon SWF 接收活动任务，调用您的实施中的相应活动方法，然后将结果返回给 Amazon SWF。

决策任务的执行较复杂。工作流工作线程从 Amazon SWF 接收决策任务。决策任务实际上是询问工作流逻辑接下来做什么的请求。在通过工作流客户端启动工作流实例时，为该实例生成了第一个决策任务。在收到此决策任务后，框架开始执行使用 `@Execute` 进行注释的工作流方法中的代码。此方法执行安排活动的协调逻辑。当工作流实例的状态更改时（例如，当活动完成时），就会安排进一步的决策任务。此时，工作流逻辑可以根据活动的结果决定采取一种操作；例如，它可能决定安排另一个活动。

框架通过无缝地将决策任务转换为工作流逻辑向开发人员隐藏了所有这些详细信息。从开发人员的角度来看，代码看上去像一个常规程序。框架会使用 Amazon SWF 维护的历史记录将其映射到对 Amazon SWF 和决策任务的调用。在决策任务到达时，框架会重播插入了迄今为止已完成活动的结果的程序执行。将取消阻止等待这些结果的异步方法和活动，程序将继续执行。

下表显示了示例图像处理工作流的执行和相应的历史记录。


**缩略图工作流的执行**  

| 工作流的程序执行 | 由 Amazon SWF 维护的历史记录  | 
| --- | --- | 
| 初次执行 | 
|  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  |  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  | 
| 重放 | 
|  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  |  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  | 
| 重放 | 
|  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  |  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  | 
| 重放 | 
|  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  |  [\[See the AWS documentation website for more details\]](http://docs.aws.amazon.com/zh_cn/amazonswf/latest/awsflowguide/details.html)  | 

在调用 `processImage` 时，框架会在 Amazon SWF 中创建新的工作流实例。这是要启动的工作流实例的持久记录。程序会一直执行到调用 `downloadImage` 活动，它要求 Amazon SWF 安排活动。工作流进一步执行并为后续活动创建任务，但这些任务要到 `downloadImage` 活动完成后才能执行；因此，此回放阶段结束。Amazon SWF 会分派要执行的 `downloadImage` 活动地任务，任务完成后，会在历史记录中记录并保存结果。工作流现在可以继续执行，且 Amazon SWF 生成了一个决策任务。框架收到决策任务并重播插入了历史记录中记录的已下载图像的结果的工作流。这可以取消阻止 `createThumbnail` 的任务，并通过在 Amazon SWF 中安排 `createThumbnail` 活动任务来继续执行程序。对 `uploadImage` 重复相同的过程。程序继续以这种方式执行，直到工作流已处理了所有图像，并且没有任何待处理的任务。由于本地不存储任何执行状态，因此每个决策任务都可能在不同的计算机上执行。这使您能够轻松编写容错且可轻松扩展的程序。

## 不确定性


由于框架依赖于重放，因此编排代码（除活动实现之外的所有工作流程代码）必须具有确定性。例如，程序中的控制流不应依赖随机数或当前时间。由于这些内容会在两次调用之间发生变化，因此重播在编排逻辑中可能不会遵循相同的路径。这将导致意外结果或错误。框架提供了可用于以确定方式获取当前时间的 `WorkflowClock`。有关更多详细信息，请参阅有关[执行关联](executioncontext.md)的一节。

**注意**  
工作流实现对象的 Spring 连接不正确也可能会导致不确定性。工作流实现 bean 及其依赖的 bean 必须在工作流范围 (`WorkflowScope`) 中。例如，将工作流实现 bean 连接到保存状态并在全局上下文中的 bean 将导致意外行为。有关更多详细信息，请参阅[Spring 集成](test.md#test.spring) 一节。