理解Go语言通道
go语言的核心并发原语之一是通道（channel），它提供了一种类型安全的方式，让不同的goroutine之间进行通信和同步。通道是引用类型，通过make函数创建，例如ch := make(chan int)。未初始化的通道（即其零值）为nil。
零值通道：死锁的根源
在Go语言中，零值通道具有特殊的行为：
- 向nil通道发送数据会永久阻塞。
- 从nil通道接收数据会永久阻塞。
- 关闭nil通道会引发运行时恐慌（panic）。
这种阻塞行为是导致死锁的常见原因。当开发者创建一个通道切片时，如果只是简单地声明切片的大小，而没有对切片中的每个通道元素进行单独初始化，那么切片中的所有通道都将是零值（nil）。
考虑以下代码片段，它尝试创建一个通道切片并启动多个goroutine向这些通道发送数据：
package main
import (
"fmt"
"math/cmplx"
)
func max(a []complex128, base int, ans chan float64, index chan int) {
fmt.Printf("called for %d,%d\n", len(a), base)
maxi_i := 0
maxi := cmplx.Abs(a[maxi_i])
for i := 1; i < len(a); i++ {
if cmplx.Abs(a[i]) > maxi {
maxi_i = i
maxi = cmplx.Abs(a[i])
}
}
fmt.Printf("called for %d,%d and found %f %d\n", len(a), base, maxi, base+maxi_i)
// 尝试向通道发送数据
ans <- maxi
index <- base + maxi_i
}
func main() {
ansData := make([]complex128, 128)
numberOfSlices := 4
incr := len(ansData) / numberOfSlices
// 错误示例：创建通道切片，但通道元素未初始化
tmp_val := make([]chan float64, numberOfSlices)
tmp_index := make([]chan int, numberOfSlices)
for i, j := 0, 0; i < len(ansData); j++ {
fmt.Printf("From %d to %d - %d\n", i, i+incr, len(ansData))
// 在这里，tmp_val[j] 和 tmp_index[j] 都是 nil 通道
go max(ansData[i:i+incr], i, tmp_val[j], tmp_index[j])
i = i + incr
}
// 主goroutine尝试从通道接收数据
// 同样，这些通道也是 nil，导致永久阻塞
maximumFreq := <-tmp_index[0]
maximumMax := <-tmp_val[0]
for i := 1; i < numberOfSlices; i++ {
tmpI := <-tmp_index[i]
tmpV := <-tmp_val[i]
if tmpV > maximumMax {
maximumMax = tmpV
maximumFreq = tmpI
}
}
fmt.Printf("Max freq = %d\n", maximumFreq)
}在上述代码中，tmp_val := make([]chan float64, numberOfSlices) 和 tmp_index := make([]chan int, numberOfSlices) 这两行代码仅创建了通道切片，并将其内部的通道元素初始化为零值（nil）。随后，max goroutine尝试向这些nil通道发送数据，主goroutine也尝试从这些nil通道接收数据。由于nil通道的阻塞特性，所有相关的goroutine都会永久阻塞，最终导致程序死锁。
立即学习“go语言免费学习笔记（深入）”；
程序的输出可能会在打印一些fmt.Printf信息后停止，并最终抛出fatal error: all goroutines are asleep - deadlock!错误。
正确初始化通道以避免死锁
解决零值通道导致的死锁问题非常简单：在使用通道之前，必须通过make函数显式地初始化它们。对于通道切片，这意味着需要遍历切片，并为每个元素分配一个新的通道。
以下是修正后的代码示例：
package main
import (
"fmt"
"math/cmplx"
)
func max(a []complex128, base int, ans chan float64, index chan int) {
fmt.Printf("called for %d,%d\n", len(a), base)
maxi_i := 0
maxi := cmplx.Abs(a[maxi_i])
for i := 1; i < len(a); i++ {
if cmplx.Abs(a[i]) > maxi {
maxi_i = i
maxi = cmplx.Abs(a[i])
}
}
fmt.Printf("called for %d,%d and found %f %d\n", len(a), base, maxi, base+maxi_i)
// 向已初始化的通道发送数据
ans <- maxi
index <- base + maxi_i
}
func main() {
ansData := make([]complex128, 128)
numberOfSlices := 4
incr := len(ansData) / numberOfSlices
tmp_val := make([]chan float64, numberOfSlices)
tmp_index := make([]chan int, numberOfSlices)
for i, j := 0, 0; i < len(ansData); j++ {
// 关键修正：在这里初始化每个通道
tmp_val[j] = make(chan float64) // 创建一个非缓冲通道
tmp_index[j] = make(chan int) // 创建一个非缓冲通道
fmt.Printf("From %d to %d - %d\n", i, i+incr, len(ansData))
go max(ansData[i:i+incr], i, tmp_val[j], tmp_index[j])
i = i + incr
}
// 主goroutine从已初始化的通道接收数据
maximumFreq := <-tmp_index[0]
maximumMax := <-tmp_val[0]
for i := 1; i < numberOfSlices; i++ {
tmpI := <-tmp_index[i]
tmpV := <-tmp_val[i]
if tmpV > maximumMax {
maximumMax = tmpV
maximumFreq = tmpI
}
}
fmt.Printf("Max freq = %d\n", maximumFreq)
}通过在循环中添加 tmp_val[j] = make(chan float64) 和 tmp_index[j] = make(chan int)，我们确保了每个通道都是一个有效的、非nil的通道。这样，max goroutine可以成功地向它们发送数据，而主goroutine也可以成功地从它们接收数据，从而避免了死锁。
最佳实践与注意事项
- 通道是引用类型： 记住通道是引用类型。声明一个通道变量但未通过make初始化，其默认值为nil。
- 显式初始化： 始终确保在使用通道之前对其进行显式初始化，无论是单个通道还是通道切片中的每个元素。
- 缓冲通道： 上述示例使用了非缓冲通道（make(chan T)）。如果发送和接收操作的时序可能不对齐，或者需要一定的并发吞吐量，可以考虑使用缓冲通道（make(chan T, capacity)）。缓冲通道在缓冲区未满时发送不会阻塞，在缓冲区非空时接收也不会阻塞。
- 关闭通道： 当不再需要向通道发送数据时，应该关闭通道（close(ch)）。从已关闭的通道接收数据不会阻塞，而是立即返回零值和ok=false。向已关闭的通道发送数据会引发恐慌。
- 避免在接收端关闭通道： 通常，通道的发送方负责关闭通道，而不是接收方。这有助于避免在通道可能仍被使用时被错误关闭。
总结
Go语言中零值通道导致的死锁是一个常见的陷阱，尤其是在处理通道切片时。其核心原因是nil通道的发送和接收操作都会导致永久阻塞。通过在创建通道切片后，显式地为每个通道元素调用make函数进行初始化，可以有效避免这类死锁问题。理解通道的零值行为和正确的初始化方式，是编写健壮、高效Go并发程序的关键。
