超时停止 Goroutine 执行:Fork-Join 模型的限制
在 Go 的 fork-join 并发模型中,goroutine 的执行不能被中断一次发起。虽然可以为从通道读取设置超时,但它不会停止写入通道的 goroutine 的执行。
示例解释
在提供的代码中:
- Find 函数创建一个缓冲通道并启动一个 goroutine 在 10 点后发送响应
- select 语句有两种情况:从通道接收或者 50 毫秒后超时。
- goroutine 在超时后最终还是发送了响应,导致没有得到想要的输出实现了。
理解限制
无法中断 Goroutines 源于 Go 的 fork-join 模型:
- Goroutine 是从主线程分叉出来的,并发运行,无需直接控制。
- 连接点(例如通道通信)是唯一需要同步的实例
- 通道接收器上设置的超时对发送者 goroutine 的执行没有影响。
替代方法
因为直接中断是不可能,可能有替代方法使用:
-
上下文取消:将上下文与goroutine关联,并在超时时取消它,导致goroutine接收到信号而终止。
-
单独的进程:在单独的进程中启动goroutine,并在以下情况下终止它:必须的。
以上是超时后如何在 Go Goroutine 完成之前停止它?的详细内容。更多信息请关注PHP中文网其他相关文章!