如何取消从工作流异步调用的活动？

Question

我们希望异步调用一个长时间运行的活动，并且在一段时间后基于外部信号，想要取消该长时间运行的活动。

Async.procedure(activities::longRunningActivity)
// Execute some synchronous activities
Workflow.await(() -> !messageQueue.isEmpty());
if (messageQueue.remove(0) == "something") {
    // Cancel longRunningActivity
}

目前，活动了解取消的唯一方式是通过心跳。确保您的活动心跳，并且不吞下心跳方法抛出的异常。

Answer 1

使用取消范围：

  CancellationScope longRunningCancellationScope =
          Workflow.newCancellationScope(
                  () -> Async.procedure(activities::longRunningActivity));
  longRunningCancellationScope.run();
  // Execute some synchronous activities
  Workflow.await(() -> !messageQueue.isEmpty());
  if (messageQueue.remove(0) == "something") {
      longRunningCancellationScope.cancel();
  }