如何在不阻塞的情况下向 Go 例程发出停止信号？

向 Go 例程发出停止信号

在这种情况下，需要指示 Go 例程停止运行。主要挑战在于在不引入阻塞行为的情况下实现此信号。

建议的解决方案涉及使用辅助通道。但是，如果 go 例程在主动处理数据时尝试从该通道接收信号，则传统的通道使用将导致阻塞。

使用 Select Case

为了避免阻塞，代码可以利用带有默认子句的选择案例。这允许 go 例程继续处理数据，直到从辅助通道接收到信号：

<code class="go">go func() {
    for {
        fmt.Println("working")
        time.Sleep(1 * time.Second)
        select {
        case <-tooLate:
            fmt.Println("stopped")
            return
        case proCh <- "processed": //this why it won't block the goroutine if the timer expirerd.
        default: // adding default will make it not block
        }
        fmt.Println("done here")
    }
}()</code>

通过利用 default 子句，go 例程即使在计时器到期时也可以避免阻塞。

使用sync.Cond

另一种方法涉及使用sync.Cond而不是通道。条件变量提供了一种在 goroutine 之间等待和发出信号的方法。

结论

使用带有默认子句或sync.Cond 的辅助通道，您可以有效地向 go 例程发出停止信号运行而不诉诸阻塞行为。

以上是如何在不阻塞的情况下向 Go 例程发出停止信号？的详细内容。更多信息请关注PHP中文网其他相关文章！