Temporal中Fire and forget异步活动未执行：如何等待其被调度执行？

当你在工作流最后用Async.procedure异步调用Activity时，工作流会直接结束，导致Activity仅被调度却无法执行——因为Temporal（或Cadence）会在工作流结束时取消所有未完成的异步操作，此时Worker还没来得及拾取这个Activity任务。

要确保这个Activity被执行完成，你需要显式等待异步操作的结果，具体可以通过Async.procedure返回的Promise对象来实现：

修改后的代码示例：

private final MyActivity myActivity = Workflow.newActivityStub(MyActivity.class, activityOptions);
@Override
public SomeObject execute(Payload payload){
    SomeObject someObject = myActivity.methodA(payload);

    // 根据someObject的结果调用更多Activity

    // 保存异步调用返回的Promise
    Promise<Void> methodBPromise = Async.procedure(myActivity::methodB, payload);
    // 阻塞工作流，等待methodB执行完成
    methodBPromise.get();
    return someObject;
}

原理说明 #

Async.procedure仅负责调度异步任务，不会阻塞工作流执行。当工作流执行到return语句时，会立即进入结束流程，所有未完成的异步任务都会被终止。调用Promise.get()会让工作流暂停，直到对应的Activity执行完成（无论成功还是失败），这样就能保证Activity被Worker拾取并执行。

如果你有特殊需求，需要工作流先返回结果但仍要执行这个Activity，这种场景下不适合用异步Activity调用，建议考虑通过Signal触发额外逻辑或启动子工作流来执行该Activity，但这种方案复杂度更高，仅在必要时使用。

内容的提问来源于stack exchange，提问作者Vishal Kumar