Go 中如何优雅地终止正在运行的 Goroutine？

向 Goroutine 发出终止信号

在 Go 中，在确保应用程序正常关闭或管理资源分配时，处理 goroutine 终止至关重要。本文探讨了一种向正在运行的 goroutine 发出信号以停止执行的技术。

查询中提供的示例演示了一个无限循环的 goroutine，模拟连续处理。目标是在超过指定超时时终止此 goroutine。

最初的方法涉及使用两个通道：一个用于通信，另一个用于发出终止信号。然而，从信号通道读取数据会阻塞 goroutine，从而达不到其预期目的。

使用附加停止通道

一个有效的解决方案是引入附加停止通道，tooLate，类型为 chan struct{}。在 goroutine 内部，使用 select 语句来监视通信通道和停止通道。如果tooLate通道接收到一个值，则goroutine优雅地返回，终止其处理循环。

这是修改后的代码片段：

<code class="go">func main() {
    // tooLate channel to signal goroutine to stop
    tooLate := make(chan struct{})
    proCh := make(chan string)

    go func() {
        for {
            fmt.Println("working")
            time.Sleep(1 * time.Second)

            select {
            case <-tooLate:
                fmt.Println("stopped")
                return
            case proCh <- "processed": // Avoid blocking
            default: // Handle potential blocking
            }
            fmt.Println("done here")
        }
    }()

    // ...

    // Signal termination
    fmt.Println("too late")
    close(tooLate)

    // ...
}</code>

在此解决方案中，继续使用proCh通道通信，而tooLate通道作为终止信号。当 TooLate 通道关闭时，goroutine 会检测到这一点并退出循环。

其他注意事项

除了使用额外的通道之外，还有其他方法来向 Goroutines 发送信号，例如使用内置的sync.Cond类型对goroutine同步进行更细粒度的控制。技术的选择取决于您应用的具体要求。

以上是Go 中如何优雅地终止正在运行的 Goroutine？的详细内容。更多信息请关注PHP中文网其他相关文章！