是否可以异步执行子工作流？

Question

我正在尝试实现一个永久的工作流，它从阻塞直到消息被传递的活动开始（即Redis的BLPOP）。一旦完成，我想异步启动一个新的工作流来进行某种处理并立即返回ContinueAsNew。

我尝试使用子工作流启动处理工作流。我观察到，我的父工作流在子工作流执行之前完成。除非我处理返回的未来，但我真的不想这样做。

正确的方法是什么？是否可以在工作流中启动新的常规工作流？此类操作是作为工作流的一部分还是在活动中实现？

提前谢谢你！

Answer 1

解决方案是等待子工作流启动，然后完成或作为新的父工作流继续。

如果您使用Go Cadence客户端，则< code >工作流。ExecuteChildWorkflow返回ChildWorkflowFuture，它扩展了返回子工作流结果的< code>Future。它还具有GetChildWorkflowExectution方法，该方法返回一个< code>Future，一旦子进程启动，该方法就准备就绪。因此，要等待子工作流启动，可以使用以下代码:

f := workflow.ExecuteChildWorklfow(ctx, childFunc)
var childWE WorkflowExecution
// The following line unblocks as soon as the child is started.
if err := f.GetChildWorkflowExecution().Get(&childWE); err != nil {
   return err
}

子工作流已开始，工作流ID在< code>childWE中找到。ID并在< code>childWE中运行ID。RunID

爪哇的对应物是：

 ChildType child = Workflow.newChildWorkflowStub(ChildType.class);
 // result promise becomes ready when the child completes
 Promise<String> result = Async.function(child::executeMethod);
 // childWE promise becomes ready as soon as the child is started
 Promise<WorkflowExecution> childWE = Workflow.getWorkflowExecution(child);