Go - 永远停止带有上下文的循环

问题内容

我有一个异步进程，它应该永远持续下去，如下所示：

func asyncforevertask() {
  for {
    anytask()
  }
}

func main() {
  go asyncforevertask()

  server.run(8080)
}

我希望能够在某个请求到达服务器时停止这个 for 循环。

我知道我需要使用 context.withcancel()，但我不知道如何集成它才能工作。我知道以下语法：

for {
  select {
  case <-ctx.Done:
    return
  case <-otherCh:
    // do smh.
  }
}

但是 asyncforevertask 不是由来自任何 otherch 的信号运行的，但它会永远运行。我是一个菜鸟，非常感谢任何类型的帮助。

正确答案

您可以使用通道来执行此操作：

var stopasync = make(chan struct{})

func asyncforevertask() {
  for {
    select {
      case <-stopasync:
         return
      default:
    }
    anytask()
  }
}

要取消，只需关闭频道即可。您必须确保通道仅关闭一次，否则您会感到恐慌。

您还可以通过上下文执行此操作：

func main() {
   ctx,cancel:=context.withcancel(context.background())
   go asyncforevertask(ctx)
   ...
}

func asyncforevertask(ctx context.context) {
  for {
    select {
      case <-ctx.done():
         return
      default:
    }
    anytask()
  }
}

或者：

func asyncforevertask(ctx context.context) {
  for {
    if ctx.err()!=nil {
       return
    }
    anytask()
  }

要停止，请调用返回的 cancel 函数：

...
cancel()

如果您还需要停止 anytask，则必须经常检查通道关闭或上下文关闭并从任务返回。

以上是Go - 永远停止带有上下文的循环的详细内容。更多信息请关注PHP中文网其他相关文章！