我有一个应该永远持续的异步进程，看起来是这样的:
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不是由任何其他CH发出的信号运行的，而是永远运行.我是个菜鸟，任何类型的帮助我都会很感激.
您可以使用频道执行此操作:
var stopAsync = make(chan struct{})
func asyncForeverTask() {
for {
select {
case <-stopAsync:
return
default:
}
anyTask()
}
}
要取消，只需关闭频道即可.你必须确保频道只关闭一次，否则你会panic 的.
您也可以在有上下文的情况下执行此操作:
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，您必须经常判断通道关闭或上下文关闭，然后从任务返回.