概述
建议先阅读 range, 阻塞通道, 非阻塞通道 等小节。
range 除了可以遍历字符串、切片、数组等数据结构外，还可以遍历通道。
语法规则
和遍历其他数据结构不同，遍历通道时没有 索引 的概念，只有值，语法如下:
for v := range ch { // v 是从通道接收到的值
// do something ...
}
使用规则
-
1. 遍历一个空的通道 (值为 nil) 时，阻塞
-
2. 遍历一个阻塞 && 未关闭的通道时，阻塞
-
3. 遍历一个阻塞 && 已关闭的通道时，不做任何事情
-
4. 遍历一个非阻塞 && 未关闭的通道时，就接收通道内的所有缓存数据，然后阻塞
-
5. 遍历一个非阻塞 && 已关闭的通道时，就接收通道内的所有缓存数据，然后返回
例子
遍历一个空的通道
package main
import (
"fmt"
"time"
)
func main() {
var done chan bool
go func() {
for v := range done {
fmt.Printf("v = %v\n", v)
break
}
fmt.Println("range broken") // 执行不到这里
}()
time.Sleep(time.Second)
}
// $ go run main.go
// 没有任何输出
遍历一个阻塞 && 未关闭的通道
package main
import (
"fmt"
"time"
)
func main() {
done := make(chan bool)
go func() {
for v := range done {
fmt.Printf("v = %v\n", v)
break
}
fmt.Println("range broken") // 执行不到这里
}()
time.Sleep(time.Second)
}
// $ go run main.go
// 没有任何输出
遍历一个阻塞 && 已关闭的通道
package main
func main() {
ch := make(chan string)
close(ch)
for v := range ch {
println(v)
}
}
// $ go run main.go
// 没有任何输出
遍历一个非阻塞 && 未关闭的通道
通道中无缓存数据，阻塞
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan string, 1)
go func() {
for v := range ch {
fmt.Printf("v = %v\n", v)
break
}
fmt.Println("range broken") // 执行不到这里
}()
time.Sleep(time.Second)
}
// $ go run main.go
// 没有任何输出
通道中有 1 个数据
package main
func main() {
ch := make(chan string, 1)
ch <- "hello world"
for v := range ch {
println(v)
}
// 代码执行不到这里
close(ch)
}
// $ go run main.go
// 输出如下
/**
v = hello world
*/
通道中有多个数据
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan string, 3)
for i := 0; i < 3; i++ {
ch <- "hello world"
}
go func() {
for v := range ch {
fmt.Printf("v = %v\n", v)
}
fmt.Println("range broken") // 执行不到这里
}()
time.Sleep(time.Second)
}
// $ go run main.go
// 输出如下
/**
v = hello world
v = hello world
v = hello world
*/
遍历一个非阻塞 && 已关闭的通道时
通道中无缓存数据，直接返回
package main
func main() {
ch := make(chan string, 1)
close(ch)
for v := range ch {
println(v)
}
}
// $ go run main.go
// 没有输出
通道中有 1 个数据
package main
func main() {
ch := make(chan string, 1)
ch <- "hello world"
close(ch)
for v := range ch {
println(v)
}
}
// $ go run main.go
// 输出如下
/**
hello world
*/
通道中有多个数据
package main
func main() {
ch := make(chan string, 3)
for i := 0; i < 3; i++ {
ch <- "hello world"
}
close(ch)
for v := range ch {
println(v)
}
}
// $ go run main.go
// 输出如下
/**
hello world
hello world
hello world
*/
联系我
