Go Goroutine与并发执行概述
go语言以其内置的并发原语——goroutine和channel而闻名。goroutine是一种轻量级的执行线程，由go运行时管理，可以高效地实现并发编程。通过go关键字，我们可以轻松地启动一个新的goroutine来执行一个函数，使其与主程序流并行运行。
例如，以下代码尝试在一个新的goroutine中打印一条消息：
package main
import (
"fmt"
)
func test() {
fmt.Println("test")
}
func main() {
go test()
}然而，当我们运行这段代码时，会发现它没有任何输出。程序似乎瞬间执行完毕，既没有打印“test”，也没有报错。这对于初学者来说可能是一个困惑点。
Goroutine的生命周期与主协程的关系
问题的核心在于Go程序的执行模型。Go程序的主入口点是main函数，它运行在一个被称为“主goroutine”的特殊goroutine中。当main函数执行完毕，即主goroutine终止时，整个Go程序也会随之终止，无论是否有其他非主goroutine仍在运行或等待执行。
在上述示例中，go test()语句确实启动了一个新的goroutine来执行test函数。但是，由于main函数在启动test goroutine后没有任何其他操作，它会立即执行到末尾并退出。此时，test goroutine可能还没有来得及被Go调度器选中并执行，或者即使被选中，也可能在打印“test”之前，整个程序就已经被主goroutine的退出而强制终止了。因此，我们看不到任何输出。
确保Goroutine执行的方法
为了确保子goroutine有足够的时间来执行其任务，我们需要某种机制来让主goroutine“等待”子goroutine完成。
方法一：使用time.Sleep（仅用于演示和简单测试）
最直接但非生产级的方法是让主goroutine暂停一段时间，给子goroutine留出执行时间。
package main
import (
"fmt"
"time" // 引入 time 包
)
func test() {
fmt.Println("test")
}
func main() {
go test()
// 让主goroutine等待10秒，给test goroutine足够的时间执行
time.Sleep(10 * time.Second)
}输出：
test
解释： 通过time.Sleep(10 * time.Second)，主goroutine会暂停执行10秒。在这段时间内，Go运行时有机会调度并执行test goroutine，使其能够打印出“test”。10秒后，主goroutine继续执行（如果还有其他代码），最终退出，但此时test goroutine的任务已经完成。
注意事项： time.Sleep是一种粗略的同步方式，不适用于生产环境。它并不能保证子goroutine一定会在指定时间内完成，也无法精确地知道子goroutine何时完成。如果子goroutine的任务耗时更长，或者任务完成得更快，time.Sleep都显得不合适。
方法二：使用sync.WaitGroup（推荐用于多goroutine同步）
在实际应用中，推荐使用sync.WaitGroup来精确地等待一组goroutine完成。WaitGroup提供了一种计数机制：
- Add(delta int)：增加等待的goroutine数量。
- Done()：减少等待的goroutine数量，通常在goroutine完成任务时调用。
- Wait()：阻塞主goroutine，直到等待的计数器归零。
package main
import (
"fmt"
"sync" // 引入 sync 包
)
func test(wg *sync.WaitGroup) {
defer wg.Done() // 确保在函数退出时调用 Done()
fmt.Println("test")
}
func main() {
var wg sync.WaitGroup // 声明一个 WaitGroup
wg.Add(1) // 增加一个等待的goroutine
go test(&wg) // 启动goroutine，并传入 WaitGroup 的指针
wg.Wait() // 阻塞主goroutine，直到所有等待的goroutine都调用 Done()
fmt.Println("主goroutine结束")
}输出：
test 主goroutine结束
解释：
- main函数创建一个sync.WaitGroup实例wg。
- wg.Add(1)将计数器设置为1，表示有一个goroutine需要等待。
- go test(&wg)启动test goroutine，并将wg的地址传递给它。
- 在test函数内部，defer wg.Done()确保在test函数返回前（无论正常返回还是发生panic），wg.Done()会被调用，将计数器减1。
- wg.Wait()会阻塞main goroutine，直到wg的计数器变为0。当test goroutine完成并调用wg.Done()后，计数器变为0，main goroutine解除阻塞，继续执行后续代码。
这种方法精确且高效，是管理多个goroutine生命周期的标准实践。
方法三：使用通道（Channel）进行通信和同步
通道不仅用于goroutine之间的数据通信，也可以用于同步。例如，一个goroutine完成任务后，可以向通道发送一个信号，主goroutine通过接收这个信号来得知子goroutine已完成。
package main
import (
"fmt"
)
func test(done chan bool) {
fmt.Println("test")
done <- true // 向通道发送完成信号
}
func main() {
done := make(chan bool) // 创建一个无缓冲的布尔类型通道
go test(done) // 启动goroutine，并传入通道
<-done // 阻塞主goroutine，直到从通道接收到信号
fmt.Println("主goroutine结束")
}输出：
test 主goroutine结束
解释：
- main函数创建一个无缓冲的bool类型通道done。
- go test(done)启动test goroutine，并将通道传递给它。
- 在test函数中，打印消息后，done
- 在main函数中，
总结
当Go程序中的子goroutine没有按预期执行时，最常见的原因是主goroutine在其完成之前就退出了。为了解决这个问题，我们需要在主goroutine和子goroutine之间建立同步机制，确保主goroutine能够等待子goroutine完成其任务。
虽然time.Sleep可以用于简单的演示，但在实际开发中，应优先使用sync.WaitGroup来管理一组goroutine的生命周期，或使用通道（Channel）进行更复杂的通信和同步。理解Go程序的并发模型和goroutine的生命周期是编写健壮、高效并发程序的关键。
