Go并发模式实战：优雅关闭goroutine

Go并发模式实战：优雅关闭goroutine

在Go并发编程中，如何优雅地停止goroutine是一个常见但容易被忽视的问题。直接让goroutine自行退出而不进行清理，可能导致资源泄漏或数据不一致。今天我们来探讨几种优雅关闭goroutine的实践方法。

使用通道传递关闭信号

最经典的方案是通过channel传递停止信号：

func worker(stopChan chan struct{
   }) {
   
    for {
   
        select {
   
        case <-stopChan:
            // 清理资源
            return
        default:
            // 正常工作
        }
    }
}

主程序通过关闭stopChan或发送信号来通知goroutine退出。

context.Context方案

Go 1.7引入的context包为此提供了标准解决方案：

func worker(ctx context.Context) {
   
    for {
   
        select {
   
        case <-ctx.Done():
            // 收到取消信号，清理后退出
            cleanup()
            return
        default:
            performTask()
        }
    }
}

通过context.WithCancel创建可取消的context，需要停止时调用cancel函数即可。

实践建议

1. 避免忙等待：在select中使用default分支时，确保有适当的休眠
2. 超时控制：使用context.WithTimeout设置最大运行时间
3. 等待所有goroutine退出：配合sync.WaitGroup确保清理完成

优雅关闭不仅是技术问题，更是对系统稳定性的负责。合理的退出机制能让你的Go应用更加健壮可靠。

你在实际项目中是如何处理goroutine生命周期的呢？欢迎分享你的实践！