问题内容
我有一个异步进程，它应该永远持续下去，如下所示：
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，则必须经常检查通道关闭或上下文关闭并从任务返回。
