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中文網其他相關文章！