当go主协程在子协程完成其任务前退出时，子协程中的defer语句可能不会被执行。这是由于缺乏显式同步导致的竞态条件。本文将深入解析这一现象，并提供使用sync.waitgroup或通道进行协程同步的专业实践，确保所有协程都能正常完成工作并执行其延迟函数。
引言：Goroutine Defer的“未调用”之谜
在Go语言中，defer语句用于确保函数在即将返回前执行特定的清理操作。当它与并发原语Goroutine结合使用时，有时会观察到出乎意料的行为。考虑以下Go程序示例：
package mainimport ( "fmt" "time")func main() { fmt.Println("1") defer fmt.Println("-1") // 主协程的defer go func() { fmt.Println("2") defer fmt.Println("-2") // 子协程的defer time.Sleep(9 * time.Second) // 子协程执行长时间任务 }() time.Sleep(1 * time.Second) // 主协程等待1秒 fmt.Println("3")}
这段代码的预期输出可能包括子协程的defer语句，例如 1 2 3 -2 -1。然而，实际输出却是 1 2 3 -1。子协程中的 fmt.Println(“-2”) 并没有被执行。这种现象并非Go语言的bug，而是对Goroutine生命周期和程序退出机制的误解所致。
Go程序与Goroutine的生命周期
要理解上述行为，关键在于掌握Go程序的执行流程和Goroutine的生命周期：
主Goroutine的特殊性：当Go程序启动时，main函数会在一个特殊的主Goroutine中运行。这个主Goroutine是整个程序的入口点。程序终止条件：Go程序会在主Goroutine执行完毕后立即终止。这意味着，如果主Goroutine在其他并发运行的Goroutine完成工作之前退出，那么所有尚未完成的Goroutine（包括它们的defer栈）都会被强制终止，而不会有机会执行它们内部的defer语句。defer语句的执行时机：defer语句安排的函数会在其所在的函数（或Goroutine）即将返回时执行。如果Goroutine在正常返回之前就被程序终止，那么其defer队列中的函数将永远不会被调用。
在上述示例中，主Goroutine在启动子Goroutine后，仅仅通过 time.Sleep(1 * time.Second) 等待了1秒。而子Goroutine被安排执行一个长达9秒的 time.Sleep 任务。显然，主Goroutine会在子Goroutine完成其9秒睡眠之前就结束其1秒的等待，并继续执行 fmt.Println(“3”)，然后主Goroutine自身返回。此时，Go程序立即终止，导致仍在睡眠中的子Goroutine被强制结束，其内部的 defer fmt.Println(“-2”) 自然也就没有机会执行了。
误区辨析：runtime.Gosched()并非万能药
在某些情况下，开发者可能会尝试使用 runtime.Gosched() 来解决此类问题，认为它可以让出CPU，从而让其他Goroutine有机会运行。例如，在主Goroutine的末尾添加 runtime.Gosched()。然而，runtime.Gosched() 的作用是让当前Goroutine放弃CPU，让调度器有机会运行其他Goroutine。它并不能保证其他Goroutine一定会完成，更不能阻止主Goroutine在自身逻辑完成后退出。因此，runtime.Gosched() 并非解决Goroutine同步问题的通用方案，它只是一种调度提示，而非同步机制。
解决方案：显式同步的重要性
Go语言倡导“不要通过共享内存来通信，而应通过通信来共享内存”的并发哲学。为了确保子Goroutine能够完成其任务并执行其defer语句，我们必须在主Goroutine中显式地等待子Goroutine的完成。Go标准库提供了多种同步原语来实现这一目标，其中最常用的是 sync.WaitGroup 和通道（channel）。
实践一：使用sync.WaitGroup等待Goroutine完成
sync.WaitGroup 是一个计数器，用于等待一组Goroutine完成。它的工作原理如下：
Add(delta int)：增加内部计数器的值。通常在启动Goroutine之前调用，表示要等待的Goroutine数量。Done()：减少内部计数器的值。通常在Goroutine即将完成其工作时调用（常配合defer使用）。Wait()：阻塞当前Goroutine，直到内部计数器归零。
通过 sync.WaitGroup，我们可以精确地控制主Goroutine，使其等待所有子Goroutine完成后再退出。
以下是使用 sync.WaitGroup 修正后的示例代码：
package mainimport ( "fmt" "sync" // 引入sync包 "time")func main() { var wg sync.WaitGroup // 声明一个WaitGroup fmt.Println("1") defer fmt.Println("-1") // 主协程的defer wg.Add(1) // 增加计数器，表示要等待一个Goroutine go func() { defer wg.Done() // Goroutine完成时调用Done()，减少计数器 fmt.Println("2") defer fmt.Println("-2") // 子协程的defer time.Sleep(3 * time.Second) // 模拟子协程执行任务 fmt.Println("子协程任务完成") }() // 注意：这里主协程不再需要长时间的time.Sleep， // 因为wg.Wait()会阻塞直到子协程完成 // time.Sleep(1 * time.Second) // 移除或缩短主协程的等待 fmt.Println("3") wg.Wait() // 阻塞主协程，直到所有wg.Add(1)对应的wg.Done()都被调用 fmt.Println("主协程等待结束")}
输出：
Ai Mailer
使用Ai Mailer轻松制作电子邮件
49 查看详情
132子协程任务完成-2主协程等待结束-1
解析：
在启动子Goroutine之前，wg.Add(1) 将等待组的计数器设置为1。子Goroutine内部，defer wg.Done() 确保无论子Goroutine如何退出（正常完成或panic），都会调用 wg.Done() 来减少计数器。主Goroutine在打印 “3” 之后，调用 wg.Wait()。此时，主Goroutine会阻塞，直到子Goroutine执行 wg.Done()，使计数器归零。子Goroutine有足够的时间完成其 time.Sleep(3 * time.Second) 任务，并执行其 defer fmt.Println(“-2”)。一旦子Goroutine调用 wg.Done()，主Goroutine的 wg.Wait() 解除阻塞，继续执行后续代码，并最终执行主Goroutine的 defer fmt.Println(“-1”)。
通过 sync.WaitGroup，我们成功地实现了主Goroutine对子Goroutine的等待，确保了子Goroutine的完整执行，包括其defer语句。
实践二：使用通道进行同步（简述）
通道（channel）是Go语言中用于Goroutine之间通信和同步的强大工具。虽然 sync.WaitGroup 更适合等待一组Goroutine完成，但通道在需要传递数据或进行更复杂协调时更为灵活。
例如，可以通过在子Goroutine完成时向一个通道发送一个信号，然后在主Goroutine中接收这个信号来达到同步的目的：
package mainimport ( "fmt" "time")func main() { done := make(chan bool) // 创建一个无缓冲的布尔通道 fmt.Println("1") defer fmt.Println("-1") go func() { fmt.Println("2") defer fmt.Println("-2") time.Sleep(3 * time.Second) fmt.Println("子协程任务完成") done <- true // 任务完成后发送信号 }() fmt.Println("3") <-done // 阻塞主协程，直到从通道接收到信号 fmt.Println("主协程等待结束")}
这种方法同样能确保子Goroutine的 defer 语句被执行。选择 sync.WaitGroup 还是通道，取决于具体的业务场景和同步需求。如果只是简单地等待一组Goroutine完成，sync.WaitGroup 更简洁；如果需要Goroutine之间传递数据或进行更精细的控制，通道则更为合适。
总结与最佳实践
理解Go Goroutine的生命周期和程序退出机制对于编写健壮的并发程序至关重要。当启动非主Goroutine执行任务时，务必考虑如何与主Goroutine进行同步，以确保它们有机会完成工作并执行其清理逻辑（defer语句）。
关键要点：
Go程序在主Goroutine退出时终止，不会等待其他活跃的子Goroutine。被强制终止的Goroutine不会执行其defer栈上的函数。time.Sleep 是一种粗糙且不可靠的同步方式，应避免用于Goroutine间的协调。使用 sync.WaitGroup 或通道等Go提供的同步原语，是实现Goroutine间正确同步的专业方法。
在设计并发程序时，始终将显式同步作为核心考量，这将有助于避免因Goroutine生命周期问题导致的意外行为和潜在的资源泄露。
以上就是理解Go Goroutine的Defer行为与正确同步实践的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1017712.html
微信扫一扫 
支付宝扫一扫 
