执行关联

该框架为工作流程和活动实现提供环境上下文。该上下文是处理的任务特有的，并提供一些可在您的实现中使用的实用工具。每次工作线程处理新任务时，将会创建一个上下文对象。

决策上下文

在执行决策任务时，该框架通过 DecisionContext 类为工作流程实现提供上下文。DecisionContext 提供上下文敏感信息，如工作流程执行运行 ID 以及时钟和计时器功能。

在工作流程实现中访问 DecisionContext

您可以使用 DecisionContextProviderImpl 类在您的工作流程实现中访问 DecisionContext。或者，您也可以使用 Spring 在您的工作流程实现的字段或属性中注入上下文，如“可测性和依赖关系注入”一节中所示。

DecisionContextProvider contextProvider
    = new DecisionContextProviderImpl();
DecisionContext context = contextProvider.getDecisionContext();

创建时钟和计时器

DecisionContext 包含一个 WorkflowClock 类型的属性，它提供计时器和时钟功能。由于工作流程逻辑需要是确定性的，因此，不应在您的工作流程实现中直接使用系统时钟。WorkflowClock 上的 currentTimeMills 方法返回处理的决策的启动事件的时间。这可确保在重播期间获得相同的时间值，从而使您的工作流程逻辑具有确定性。

WorkflowClock 还具有一个返回 Promise 对象的 createTimer 方法，该对象在指定的间隔后变为就绪状态。您可以将该值作为其他异步方法的参数，以将其执行推迟指定的一段时间。这样，您实际上可以将异步方法或活动安排在以后的时间执行。

以下列表中的示例说明了如何定期调用活动。

@Workflow
@WorkflowRegistrationOptions(defaultExecutionStartToCloseTimeoutSeconds = 60,
               defaultTaskStartToCloseTimeoutSeconds = 10)
public interface PeriodicWorkflow {

    @Execute(version = "1.0")
    void periodicWorkflow();
}

@Activities(version = "1.0")
@ActivityRegistrationOptions(defaultTaskScheduleToStartTimeoutSeconds = 300,
                             defaultTaskStartToCloseTimeoutSeconds = 3600)
public interface PeriodicActivity {
    void activity1();
}

public class PeriodicWorkflowImpl implements PeriodicWorkflow {

    private DecisionContextProvider contextProvider
         = new DecisionContextProviderImpl();

    private WorkflowClock clock
         = contextProvider.getDecisionContext().getWorkflowClock();

    @Override
    public void periodicWorkflow() {
        callPeriodicActivity(0);
    }

    @Asynchronous
    private void callPeriodicActivity(int count,
                                      Promise<?>... waitFor) {
        if (count == 100) {
            return;
        }
        PeriodicActivityClient client = new PeriodicActivityClientImpl();
        // call activity
        Promise<Void> activityCompletion = client.activity1();

        Promise<Void> timer = clock.createTimer(3600);

        // Repeat the activity either after 1 hour or after previous activity run
        // if it takes longer than 1 hour
        callPeriodicActivity(count + 1, timer, activityCompletion);
    }
}


public class PeriodicActivityImpl implements PeriodicActivity
{
@Override
   public void activity1() {
      ...
      }
}      

在上述列表中，callPeriodicActivity 异步方法调用 activity1，然后使用当前 AsyncDecisionContext 创建一个计时器。它将返回的 Promise 作为参数传递到对其自身的递归调用。该递归调用等到计时器触发 (本示例中为 1 小时)，然后再执行。

活动执行上下文

就像 DecisionContext 在处理决策任务时提供上下文信息一样，ActivityExecutionContext 在处理活动任务时提供类似的上下文信息。将通过 ActivityExecutionContextProviderImpl 类为您的活动代码提供该上下文。

ActivityExecutionContextProvider provider
    = new ActivityExecutionContextProviderImpl();
ActivityExecutionContext aec = provider.getActivityExecutionContext();

通过使用 ActivityExecutionContext，您可以执行以下操作：

为长时间运行的活动提供检测信号

如果活动长期运行，则必须定期向 Amazon SWF 报告进度，让它知道任务仍在进行中。如果没有此类检测信号，并且在注册活动类型或计划活动时设置了任务检测信号超时，则任务可能会超时。要发送检测信号，您可以在 recordActivityHeartbeat 上使用 ActivityExecutionContext 方法。检测信号还提供了一个机制以取消正在执行的活动。有关更多详细信息和示例，请参阅错误处理一节。

获取活动任务详细信息

如果需要，您可以获取 Amazon SWF 在执行程序获取任务时传递的所有活动任务详细信息。这包括有关任务输入、任务类型和任务令牌等的信息。如果要实施手动完成的活动（例如，通过人工操作完成），则必须使用 ActivityExecutionContext 来检索任务令牌，并将其传递给最终完成活动任务的流程。有关更多详细信息，请参阅有关手动完成活动的一节。

获取执行程序使用的 Amazon SWF 客户端对象

执行程序使用的 Amazon SWF 客户端对象可以通过调用 ActivityExecutionContext 上的 getService 方法来获取。如果您想直接调用 Amazon SWF 服务，这会非常有用。