
本文旨在详细解释Go语言中通道操作符 goroutine之间传递数据。它既可以用于从通道接收数据,也可以用于向通道发送数据,是实现并发同步和通信的关键。理解
Go语言中的通道(channel)是goroutine之间进行通信和同步的重要机制。而操作符
通道的发送操作
当
channel <- value
其中,channel 是一个通道变量,value 是要发送的数据。这个操作会将 value 发送到 channel 中。如果通道没有缓冲区,发送操作会阻塞,直到有另一个goroutine从该通道接收数据。如果通道有缓冲区,且缓冲区未满,发送操作会立即执行。
立即学习“go语言免费学习笔记(深入)”;
示例:
package main
import "fmt"
func main() {
ch := make(chan int) // 创建一个无缓冲通道
go func() {
ch <- 10 // 向通道发送数据
fmt.Println("发送完成")
}()
val := <-ch // 从通道接收数据
fmt.Println("接收到:", val)
}在这个例子中,一个goroutine向通道 ch 发送了整数 10。主goroutine从通道接收了这个值,并打印出来。
通道的接收操作
当
value := <-channel
或者,也可以不接收值:
易通企业网站系统 别名CmsEasy 是国内唯一免费微信+手机端+微网站+手机短信+在线销售+多语言网站组合的企业营销管理平台,易通企业网站系统也称易通企业网站程序,是易通公司开发中国首套免费提供企业网站模板的营销型企业网站管理系统,系统前台生成html、完全符合SEO、同时有在线客服、潜在客户跟踪、便捷企业网站模板制作、搜索引擎推广等功能的企业网站系统。
<-channel
第一种形式会将从 channel 接收到的数据赋值给变量 value。第二种形式则仅仅是从通道中取出数据,但不使用它。这种形式常用于同步goroutine,例如等待某个事件发生。如果通道为空,接收操作会阻塞,直到有另一个goroutine向该通道发送数据。
示例:
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan bool)
go func() {
time.Sleep(2 * time.Second) // 模拟耗时操作
ch <- true // 发送信号
fmt.Println("信号已发送")
}()
<-ch // 阻塞,直到接收到信号
fmt.Println("接收到信号,程序继续执行")
}在这个例子中,主goroutine通过
通道的关闭和range循环
可以使用 close(channel) 函数关闭通道。关闭后的通道不能再发送数据,但仍然可以接收数据,直到通道为空。可以使用 range 循环遍历通道,直到通道关闭且为空。
示例:
package main
import "fmt"
func main() {
ch := make(chan int, 3) // 创建一个带缓冲的通道
ch <- 1
ch <- 2
ch <- 3
close(ch) // 关闭通道
for val := range ch {
fmt.Println(val)
}
}在这个例子中,我们向带缓冲的通道 ch 发送了三个整数,然后关闭了通道。range ch 循环会遍历通道中的所有数据,直到通道关闭且为空。
注意事项
- 死锁: 如果所有goroutine都在等待某个通道的操作,而没有任何goroutine执行发送或接收操作,就会发生死锁。
- 关闭已关闭的通道: 重复关闭同一个通道会导致panic。
- 发送到已关闭的通道: 向已关闭的通道发送数据会导致panic。









