如何管理 Go 例程并停止特定的 Go 例程

Question

这是真实情况的抽象示例，我必须通过调用 func B （func A）来停止由 func A 创建的某些特定 go 例程

func A(context, interval, ...params) {
 go (interval) {
    tk := time.ticker(interval)
    for {
      select {
       case <- tk.C:
        err := func C(params)
     }
    }
  }(interval)
}

（func A）使用特定参数以重复间隔创建 go 例程执行（func C）。

func B(context, ...params) {
  // stop go routine that runs func C with specific params.
}

(func B) 需要使用给定参数停止 go 例程运行 (func C)。 另外，我如何处理（func A）中的错误和上下文超时等情况。

注意：提供了伪代码，抱歉无法共享真实代码。

Answer 1

我相信您正在寻找 context.Done。

Done 返回一个通道，当应取消代表此上下文完成的工作时，该通道已关闭。

select {
case <-ctx.Done():
    // context was cancelled, stop goroutine
    return
case <-tk.C:
    C(params...)
}

工作示例： https://go.dev/play/p/wSUHSHCse7D< /a>

没有简单的方法可以根据参数查找 goroutine，因此您必须稍微调整代码以选择要取消的上下文。