中断长时间优步节奏活动的正确方法是什么？

Question

如果我有一个长期的活动，比如

func Activity(ctx context.Context) error {
    ticker := time.NewTicker(5 * time.Second)
    for {
        select {
        case <-ctx.Done():
            return ctx.Err()
        case <-ticker.C:
            if isServiceReady(ctx) {
                break
            }
        }
    }
    return nil
}

我希望能够从工作流程中取消它（而不会取消整个工作流程），然后我将如何做到这一点？

我曾希望您可以在上下文Done通道上接收，然后在工作流中创建一个可取消的上下文，但这显然无济于事。

Answer 1

当前要取消活动，必须心跳。Cadence服务将取消状态附加到活动心跳返回值上。因此，如果您在每一次心跳时都开始心跳，并且心跳间隔足够小（因为客户端不会在每次心跳方法调用时都调用服务），那么您的代码应该可以开始工作了。

未来，我们计划添加一个会话的概念，其中包含一个特定于工人的任务列表，以提供取消。添加后，取消将不依赖于发送的心跳。