Golangchannel关闭与循环读取示例-Golang-PHP中文网

Golangchannel关闭与循环读取示例

P粉602998670

发布： 2025-10-07 20:06:02

原创

655人浏览过

关闭channel由发送方执行，使用close()函数，接收方不应关闭；关闭后可读取剩余数据，随后返回零值，向已关闭channel发送数据会引发panic。

golangchannel关闭与循环读取示例

在Go语言中，channel 是实现goroutine之间通信的重要机制。理解如何正确关闭 channel 以及如何安全地循环读取数据，是编写健壮并发程序的关键。

关闭Channel的规则

关闭 channel 表示不再有值发送到该 channel。尝试向已关闭的 channel 发送数据会引发 panic，而从已关闭的 channel 读取仍可进行，会依次返回剩余数据，之后返回零值。

通常由发送方负责关闭 channel，接收方不应关闭它。使用 close() 函数来关闭 channel：

ch := make(chan int, 3)
ch <- 1
ch <- 2
close(ch)

登录后复制

使用for-range循环读取channel

for-range 可以自动检测 channel 是否关闭。当 channel 关闭且所有数据被读取后，循环自动退出。

立即学习“go语言免费学习笔记（深入）”；

示例：启动一个goroutine发送数据并关闭channel，主函数用range读取：

芦笋演示

一键出成片的录屏演示软件，专为制作产品演示、教学课程和使用教程而设计。

查看详情

func main() {
    ch := make(chan string, 2)
<pre class='brush:php;toolbar:false;'>go func() {
    ch <- "Hello"
    ch <- "World"
    close(ch) // 发送完成后关闭
}()

for msg := range ch {
    fmt.Println(msg)
}
// 输出：
// Hello
// World

登录后复制

}

通过逗号ok模式判断channel状态

如果不想使用 range，可以用 <-chan 配合 ok 判断是否关闭：

for {
    if msg, ok := <-ch; ok {
        fmt.Println(msg)
    } else {
        fmt.Println("Channel closed")
        break
    }
}
</font>

登录后复制

实际应用场景：任务分发与结果收集

常见模式：多个worker从同一个channel读取任务，主程序关闭任务channel后等待结果。

func main() {
    tasks := make(chan int, 10)
    results := make(chan int, 10)
<pre class='brush:php;toolbar:false;'>// 启动worker
for w := 0; w < 3; w++ {
    go func() {
        for task := range tasks {
            results <- task * 2
        }
    }()
}

// 发送任务
for i := 1; i <= 5; i++ {
    tasks <- i
}
close(tasks) // 所有任务发送完毕，关闭

// 收集结果
for i := 0; i < 5; i++ {
    fmt.Println(<-results)
}

close(results)

登录后复制

}

基本上就这些。关键是记住：只由发送者关闭，接收者通过 range 或 ok 模式安全读取。避免重复关闭或向关闭的 channel 发送数据。

以上就是Golangchannel关闭与循环读取示例的详细内容，更多请关注php中文网其它相关文章！