go语言中，缓冲通道在容量满时会阻塞发送者。理解并发的关键在于区分哪个goroutine被阻塞。如果主goroutine因通道满而阻塞，go运行时会检测到死锁并报错。然而，如果阻塞发生在子goroutine中，主goroutine将继续执行并最终退出，导致程序终止，此时子goroutine会被静默终止，而不会报告死锁错误。
在Go语言的并发模型中，通道（Channel）是实现Goroutine之间通信和同步的关键机制。通道可以是有缓冲的，也可以是无缓冲的。理解通道的缓冲行为、Goroutine的阻塞特性以及Go程序的退出机制，对于编写健壮的并发代码至关重要。
Go语言中的通道在创建时可以指定一个容量，这就是所谓的缓冲通道。
下面是一个在主Goroutine中操作缓冲通道的示例，展示了当缓冲区满时发送操作会阻塞：
package main
import "fmt"
func main() {
c := make(chan int, 2) // 创建一个容量为2的缓冲通道
c <- 1 // 缓冲区未满，发送成功
c <- 2 // 缓冲区未满，发送成功
fmt.Println("已发送1和2")
// 尝试发送第三个值，此时缓冲区已满，此行代码将阻塞主Goroutine
// 如果没有其他Goroutine读取，程序将死锁
// c <- 3
// fmt.Println("已发送3") // 此行不会被执行
// 为了避免死锁，我们可以先读取
fmt.Println("从通道接收:", <-c) // 接收一个值，缓冲区腾出空间
c <- 3 // 缓冲区有空间，发送成功
fmt.Println("已发送3")
fmt.Println("最终从通道接收:", <-c)
fmt.Println("最终从通道接收:", <-c)
}在上述代码中，如果取消注释 c <- 3 且不进行任何读取操作，主Goroutine将在尝试发送第三个值时被阻塞。由于没有其他Goroutine进行读取来解除阻塞，Go运行时会检测到所有Goroutine都处于休眠状态（即死锁），并报告运行时错误。
立即学习“go语言免费学习笔记（深入）”；
Goroutine是Go语言中轻量级的并发执行单元。通过 go 关键字，我们可以将一个函数调用放到一个新的Goroutine中执行。这使得程序能够同时执行多个任务，从而避免主Goroutine因某个操作（如通道发送或接收）而长时间阻塞。
考虑以下示例，一个Goroutine向通道发送数据，而主Goroutine从通道接收数据：
package main
import (
"fmt"
"time"
)
func main() {
c := make(chan int, 2) // 容量为2的缓冲通道
go func() {
fmt.Println("子Goroutine：开始发送数据")
c <- 1 // 发送成功
c <- 2 // 发送成功
c <- 3 // 缓冲区已满，子Goroutine在此处阻塞，直到主Goroutine接收
fmt.Println("子Goroutine：发送3成功")
c <- 4 // 缓冲区已满，子Goroutine在此处阻塞
fmt.Println("子Goroutine：发送4成功")
}()
time.Sleep(100 * time.Millisecond) // 等待子Goroutine启动并发送一些数据
fmt.Println("主Goroutine：从通道接收:", <-c) // 接收1，子Goroutine的c <- 3解除阻塞
time.Sleep(100 * time.Millisecond)
fmt.Println("主Goroutine：从通道接收:", <-c) // 接收2，子Goroutine的c <- 4解除阻塞
time.Sleep(100 * time.Millisecond)
fmt.Println("主Goroutine：从通道接收:", <-c) // 接收3
time.Sleep(100 * time.Millisecond)
fmt.Println("主Goroutine：从通道接收:", <-c) // 接收4
fmt.Println("主Goroutine：程序结束")
}在这个例子中，子Goroutine在发送第三个值时会阻塞，但由于主Goroutine会适时地从通道中接收数据，子Goroutine的阻塞会被解除，程序能够正常运行。
理解Go程序何时退出以及Goroutine的生命周期是解决并发问题的核心。Go语言的规范明确指出：
程序执行从初始化 main 包开始，然后调用 main 函数。当 main 函数返回时，程序退出。它不会等待其他（非 main）Goroutine完成。
这意味着，只要 main Goroutine执行完毕，整个程序就会终止，无论其他Goroutine是否仍在运行或处于阻塞状态。那些尚未完成的子Goroutine会被Go运行时静默终止，不会有任何错误报告。
这解释了为什么在某些情况下，即使通道发送操作会导致阻塞，程序也不会报告死锁。
当主Goroutine尝试向一个已满的缓冲通道发送数据，并且没有其他Goroutine会从该通道接收数据时，主Goroutine将无限期阻塞。由于Go程序只等待主Goroutine完成，且主Goroutine被阻塞，运行时会检测到所有Goroutine都处于休眠状态，从而报告死锁。
package main
// import "fmt" // 导入fmt以便打印，但在此示例中我们期望死锁
func main() {
c := make(chan int, 2) // 容量为2的缓冲通道
c <- 1 // 发送成功
c <- 2 // 发送成功
// 此时通道已满，主Goroutine尝试发送第三个值，将在此处阻塞
// 没有其他Goroutine会读取通道，因此主Goroutine永远不会被解除阻塞
c <- 3 // 导致死锁！
// fmt.Println("主Goroutine：发送3成功") // 此行不会被执行
}运行上述代码会得到 fatal error: all goroutines are asleep - deadlock! 错误。
现在，我们分析一个看似矛盾的场景：多个子Goroutine向一个已满的通道发送数据，但程序却正常退出，没有报告死锁。这正是由于Go程序的退出策略。
考虑以下代码，它与原始问题中的代码类似：
package main
import (
"fmt"
"time"
)
func main() {
c := make(chan int, 2) // 容量为2的缓冲通道
for i := 0; i < 4; i++ {
go func(id int) {
fmt.Printf("Goroutine %d: 尝试发送第一个值\n", id)
c <- id // 发送第一个值 (缓冲区可能未满)
fmt.Printf("Goroutine %d: 成功发送第一个值 %d\n", id, id)
fmt.Printf("Goroutine %d: 尝试发送第二个值\n", id)
c <- 9 // 发送第二个值 (缓冲区可能已满，开始阻塞)
fmt.Printf("Goroutine %d: 成功发送第二个值 9\n", id)
// 此时通道很可能已经满了，后续的发送操作将导致子Goroutine阻塞
fmt.Printf("Goroutine %d: 尝试发送第三个值\n", id)
c <- 9 // 子Goroutine可能在此处阻塞
fmt.Printf("Goroutine %d: 成功发送第三个值 9\n", id)
fmt.Printf("Goroutine %d: 尝试发送第四个值\n", id)
c <- 9 // 子Goroutine可能在此处阻塞
fmt.Printf("Goroutine %d: 成功发送第四个值 9\n", id)
}(i)
}
// 主Goroutine在此处休眠一段时间，给子Goroutine执行的机会
// 但主Goroutine本身并没有尝试从通道读取或发送导致阻塞
time.Sleep(2000 * time.Millisecond)
// 如果取消注释以下代码，主Goroutine会读取通道，可能会解除子Goroutine的阻塞
/*
for i := 0; i < 4*2; i++ {
fmt.Println("主Goroutine：接收到", <-c)
}
*/
fmt.Println("主Goroutine：程序结束")
}在这个例子中：
这就是为什么在这种情况下，即使有多个Goroutine被阻塞，程序仍然“正常”退出的原因。它并非忽略了通道的缓冲大小，而是因为Go程序的退出机制不等待非主Goroutine完成。
Go语言的通道缓冲机制、Goroutine的并发执行以及程序退出策略共同构成了其强大的并发模型。理解缓冲通道在容量满时会阻塞发送者是基础，而区分是主Goroutine还是子Goroutine被阻塞，则是理解程序行为的关键。当主Goroutine阻塞时，通常会导致死锁错误。然而，如果阻塞发生在子Goroutine中，而主Goroutine能够顺利完成并退出，那么这些阻塞的子Goroutine将被静默终止，程序不会报告死锁。在设计并发程序时，务必使用 sync.WaitGroup 等合适的同步机制来确保所有必要的Goroutine都能完成其任务，从而避免潜在的数据丢失或不完整操作。
以上就是深入理解Go语言并发：通道缓冲、Goroutine阻塞与程序退出机制的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
广告
收藏
收藏
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
766
