如何终止一个正在进行的协程？

[777777]

利用 context.WithCancel()来终止协程，但存在一个问题：cancel()执行后，必须等 for 循环执行完毕 goroutine 才退出。

for {
  select {
    case <-Ctx.Done():
      return
    default:
      for i := 0; i < 100; i++ {
        // 业务逻辑
      }
  }
}

需求为：cancel()后协程立马退出不再执行后面的循环。
目前我的解决方法：单独起一个协程用来监听退出信号，然后通过全局变量通知业务逻辑循环退出。

flag := false
go func() {
  for {
    select {
      case <-Ctx.Done():
        flag = true
        return
  }
}()

for i:=0; i < 100; i++ {
  if flag {
    return
  }
  // 业务逻辑
}

请问最佳实践应该是如何退出？

是这样一个场景：用户创建任务，起一个 goroutine 去执行，执行过程中，用户想要取消这个任务。

for i := 0; i < 100; i++ {
  select {
    case <-Ctx.Done():
    return
  default:
    // 业务逻辑
  }
}

感谢大家的回答，每次循环都检测一次退出信号就好了。
延伸出另一个问题：用户取消任务，如何让default里的业务逻辑立马终止？

看了一下os.exec.cmd.Start()的源码

	if c.ctx != nil {
		c.waitDone = make(chan struct{})
		go func() {
			select {
			case <-c.ctx.Done():
				c.Process.Kill()
			case <-c.waitDone:
			}
		}()
	}

另起一个goroutine监听cancel()，然后kill掉执行的process。
类比本问题，一个协程执行任务，一个协程监听任务的cancel()，任务取消直接kill掉执行任务的协程且监听协程也退出。

[dream10201]

瞎想的，你把 select case 放到 for 循环里面不行？

[dream10201]

for {
for i := 0; i < 100; i++ {
select {
case <-Ctx.Done():
return
default:
// 业务逻辑
}
}
}

[rimutuyuan]

```
for {
for i := 0; i < 100; i++ {
select {
case <-Ctx.Done():
return
default:
// 业务逻辑
}
}
}```

[BBCCBB]

这种可以在 for 里每次检测 ctx.Done()... 不过不是最佳实践.
和你图中这个方法差不多,, 不过不知道你图中这个方法有没有变量可见性的问题? 导致 flag=true 后在当前协程并不可见?

[777777]

@BBCCBB 是可见的

[777777]

@dream10201 这样有问题吧，如果不调用 cancel()，最外面 for 循环不会退出。

[sadfQED2]

这个问题我在 java 里面也研究过，最后结果就是无解，只能业务代码里面每次循环都判断

[xx6412223]

直接退出就不是合理的设计。

[caryqy]

执行前检查 Done，

执行后提交前再次检查 Done，根据结果来收尾。

考虑的粒度即使再细都会碰到 执行中取消 这个问题，所以到某个程度之后就 禁止用户取消

[haochen2]

如果业务逻辑超时运行或着阻塞，根本走不到 ctx.Done 那个 case 的地方

[cpstar]

循环第二位置用 i<100&&ctx.done() 不好么？还非得一个 switch-case ？
至于楼上说的业务阻塞，那就得放到业务里边继续判断了。

多线程运转，直接干掉线程，哈

[MidGap]

runtime.Goexit()

[fpure]

@sadfQED2 Java 里面哪有什么协程？

[sadfQED2]

@fpure java 线程

[s4nd]

老哥，你这头像是认真的吗，nft 大佬

[MineDog]

@sadfQED2 #7 java 怎么会无解呢，java 一般就是 Interrupted+状态判断啊

[cheng6563]

@sadfQED2 Java 一顿 Interrupt 就行了，只不过没人管 InterruptedException 倒是真的

[codeface]

在 context 传递给业务逻辑
https://gist.github.com/icodeface/89aaf03d763c11ed204c1016cca8ac30

[caoyouming]

你这里的 c 表示的是什么呀？

[ltf127001]

@caoyouming 根据我在菜鸟教程学了两天 go 的经验，这个应该是个通道（ channel ）

[caoyouming]

@ltf127001 #20 if c.ctx != nil {
c.waitDone = make(chan struct{})
go func() {
select {
case <-c.ctx.Done():
c.Process.Kill()
case <-c.waitDone:
}
}()
}

这里的 c 应该不是 channel 吧？