本文探讨了 Go 语言中一个有趣的现象：当循环次数为奇数时，Go 程序能够完整输出所有数据，而当循环次数为偶数时，程序可能会丢失最后一个数据。我们将分析这种现象背后的原因，并提供解决方案，确保程序在退出前能够正确处理所有协程。
在 Go 语言中，协程（goroutine）是轻量级的并发执行单元。理解 Go 协程的调度机制以及程序退出时机的关系对于编写健壮的并发程序至关重要。以下代码展示了一个可能导致数据丢失的场景：
package main
import "runtime"
import "sync"
func main() {
c2 := make(chan int)
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
for v := range c2 {
println("c2 =", v, "numof routines:", runtime.NumGoroutine())
}
}()
for i := 1; i <= 10000; i++ { // 尝试修改为 10001
c2 <- i
}
close(c2) // 关闭channel，通知goroutine退出
wg.Wait() // 等待goroutine完成
}上述代码创建了一个协程，该协程从 channel c2 中读取数据并打印。主协程向 c2 中写入数据。一个有趣的现象是，当循环次数为偶数（例如 10000）时，程序可能无法打印所有数据，而当循环次数为奇数（例如 10001）时，程序通常能够完整输出。
原因分析
这种现象的原因在于 Go 程序的退出机制。当 main 函数返回时，程序会立即终止，而不会等待其他协程完成。在上述代码中，如果 main 函数在协程处理完所有数据之前返回，那么部分数据可能无法被打印。
奇偶循环次数的影响仅仅是表面现象，其本质是协程的调度和 main 函数的退出时机存在竞争关系。循环次数的微小变化可能导致 main 函数提前或延迟退出，从而影响协程是否能够完成所有任务。这本质上是一种概率问题，受到 Go 调度器的影响。
解决方案
为了确保程序在退出前能够正确处理所有协程，可以使用 sync.WaitGroup 来同步协程的完成状态。以下是修改后的代码：
package main
import "runtime"
import "sync"
func main() {
c2 := make(chan int)
var wg sync.WaitGroup
wg.Add(1) // 增加等待计数器
go func() {
defer wg.Done() // 协程退出时减少计数器
for v := range c2 {
println("c2 =", v, "numof routines:", runtime.NumGoroutine())
}
}()
for i := 1; i <= 10000; i++ { // 尝试修改为 10001
c2 <- i
}
close(c2) // 关闭channel，通知goroutine退出
wg.Wait() // 等待计数器归零，即等待goroutine完成
}在这个修改后的版本中，sync.WaitGroup 用于等待协程完成。wg.Add(1) 增加等待计数器，wg.Done() 在协程退出时减少计数器，wg.Wait() 阻塞 main 函数，直到计数器归零，即所有协程都已完成。
此外，close(c2) 的调用至关重要。它通知协程不再有新的数据写入 channel，从而使协程能够正常退出。
总结
Go 协程的调度和程序退出时机是并发编程中需要重点关注的问题。通过使用 sync.WaitGroup 和正确关闭 channel，可以确保程序在退出前能够正确处理所有协程，避免数据丢失和其他潜在问题。在编写并发程序时，务必考虑协程的生命周期和同步机制，以确保程序的健壮性和可靠性。
