Golang中几种通道死锁典型案例

文章目录
  1. 1. 对无缓冲通道先行写入
  2. 2. 通道未写入之前先行读取
    1. 2.1. 读取次数多于写入次数
  3. 3. 多通道写入和读取顺序不一致

Golang中通道是进行数据同步一个重要手段，当主进程读取空通道，或者向没有协程读取的通道写入时候，都会发生死锁现象（编译时候提示fatal error: all goroutines are asleep - deadlock!）。下面列出几个常见死锁情况。

对无缓冲通道先行写入

1
2
3
4
5
func main() {
	ch := make(chan int)
	ch <- 100
	fmt.Println(<-ch)
}

或者如下

1
2
3
4
5
6
7
func main() {
	ch := make(chan int)
	ch <- 100
	go func() {
		fmt.Println(<-ch)
	}()
}

以上两种情况都会发生死锁

解决办法：

  1. 使用缓存通道
1
2
3
4
5
6
func main() {
	ch := make(chan int, 1)
	ch <- 100
	fmt.Println(<-ch)

}
  1. 将通道写入放到协程中处理
1
2
3
4
5
6
7
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
	}()
	fmt.Println(<-ch)
}

通道未写入之前先行读取

1
2
3
4
5
func main() {
	ch := make(chan int)
	fmt.Println(<-ch)
	ch<-100
}

或者如下

1
2
3
4
5
6
7
8
func main() {
	ch := make(chan int)
	fmt.Println(<-ch)

	go func() {
		ch <- 100
	}()
}

以上两种情况都会发生死锁

读取次数多于写入次数

1
2
3
4
5
6
7
8
9
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
	}()
	for {
		fmt.Println(<-ch)
	}
}

或者

1
2
3
4
5
6
7
8
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
	}()

	fmt.Println(<-ch, <-ch)
}

或者

1
2
3
4
5
6
7
8
9
10
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
	}()

	for v := range ch {
		fmt.Println(v)
	}
}

以上几种情况都会发生死锁

注意下面例子情况：不会发生死锁，先输出100，通道关闭后，会一直输出0

1
2
3
4
5
6
7
go func() {
    ch <-100
    close(ch)
}()
for {
    fmt.Println(<-ch)
}

解决一直输出0可以：

  1. 判断通道是否关闭：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
		close(ch)
	}()
	for {
		input, open := <-ch
		if !open {
			break
		}
		fmt.Println(input)
	}
}
  1. 使用for-range来获取通道数据。for-range会自动检测通道是否关闭
1
2
3
4
5
6
7
8
9
10
11
func main() {
	ch := make(chan int)
	go func() {
		ch <- 100
		close(ch)
	}()

	for input := range ch {
		fmt.Println(input)
	}
}

多通道写入和读取顺序不一致

1
2
3
4
5
6
7
8
9
10
11
func main() {
	ch1 := make(chan int)
	ch2 := make(chan int)

	go func() {
		ch1 <- 100
		ch2 <- 200
	}()

	fmt.Println(<-ch2, <-ch1)
}

或者

1
2
3
4
5
6
7
8
9
10
11
12
func main() {
	ch1 := make(chan int)
	ch2 := make(chan int)

	go func() {
		fmt.Println(<-ch2, <-ch1)

	}()

	ch1 <- 100
	ch2 <- 200
}