
问题根源:主协程的快速退出
Go 程序会在 main() 函数执行完毕后退出。如果 main() 函数执行速度过快,而协程中的代码(例如,从网络连接读取数据并打印)尚未执行完毕,那么程序就会直接退出,导致协程中的 fmt.Println 语句无法执行,或者执行了但还没来得及将内容输出到标准输出。
解决方案:使用通道(Channel)进行同步
解决这个问题的一种常见方法是使用通道(channel)来同步主协程和子协程。通过创建一个通道,主协程可以等待子协程完成任务后再退出,从而保证子协程的输出能够正确显示。
以下是一个示例代码,演示了如何使用通道来同步协程:
package main
import (
"bufio"
"fmt"
"net"
)
func main() {
conn, err := net.Dial("tcp", "irc.freenode.net:6667")
if err != nil {
fmt.Println("Error connecting:", err)
return
}
defer conn.Close()
reader := bufio.NewReader(conn)
done := make(chan bool) // 创建一个通道
go func() {
defer func() {
done <- true // 子协程完成时向通道发送信号
}()
str, err := reader.ReadString('\n')
if err != nil {
fmt.Println("Error reading:", err)
return
}
fmt.Println(str)
}()
<-done // 主协程等待通道接收信号
}代码解释:
- done := make(chan bool): 创建一个类型为 bool 的通道 done。
- defer func() { done : 在子协程退出前,使用 defer 语句向 done 通道发送一个 true 值,表示子协程已完成任务。
- : 主协程从 done 通道接收数据,这会导致主协程阻塞,直到子协程向通道发送数据。这样,主协程就会等待子协程完成任务后再退出。
其他注意事项:
- 确保在协程内部处理错误,避免程序崩溃。
- 使用 defer 语句关闭网络连接等资源,防止资源泄漏。
- 除了使用通道,还可以使用 sync.WaitGroup 来同步协程,实现类似的功能。
总结:
当在 Go 协程中使用 fmt.Println 时没有输出,通常是因为主协程退出过快,导致子协程没有足够的时间执行。通过使用通道(channel)或其他同步机制,可以确保主协程等待子协程完成任务,从而保证输出能够正确显示。在编写并发程序时,理解协程的生命周期和同步机制至关重要,能够有效避免此类问题。










