
本文旨在详细解释Go语言中通道操作符
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
或者,也可以不接收值:
<-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。


















