
在Golang中,
通道与
可以将通道视为一个消息队列。
-
发送数据到通道 (Enqueue):
当通道位于
立即学习“go语言免费学习笔记(深入)”;
ch <- data // 将 data 发送到通道 ch
这里,ch 是一个通道,data 是要发送的数据。 这行代码会将 data 放入通道 ch 中。 如果通道已满,则发送操作将会阻塞,直到通道有空闲位置。
-
从通道接收数据 (Dequeue):
Golang Uber Dig下载使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器,提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象,支持命名依赖等
当通道位于
data := <-ch // 从通道 ch 接收数据,并将其赋值给 data
这里,ch 是一个通道,data 是用于存储接收到的数据的变量。 这行代码会从通道 ch 中取出数据,并将其赋值给变量 data。 如果通道为空,则接收操作将会阻塞,直到通道中有数据可供接收。
此外,也可以不将接收到的数据存储到变量中,例如:
<-ch // 从通道 ch 接收数据,但不使用
这种用法通常用于同步goroutine,类似于Java中的"wait/notify"操作。
示例代码
以下是一个简单的示例,展示了如何使用
package main
import "fmt"
func main() {
// 创建一个整型通道
ch := make(chan int)
// 启动一个goroutine发送数据
go func() {
ch <- 10 // 发送数据 10 到通道 ch
fmt.Println("发送完成")
}()
// 从通道接收数据
data := <-ch // 从通道 ch 接收数据
fmt.Println("接收到的数据:", data)
}
在这个例子中,首先创建了一个整型通道 ch。然后启动一个goroutine,向通道 ch 发送数据 10。主goroutine从通道 ch 接收数据,并打印出来。
注意事项
- 死锁: 如果所有的goroutine都在等待某个通道上的操作,而没有goroutine执行发送或接收操作,就会发生死锁。
- 关闭通道: 可以使用 close(ch) 关闭通道。关闭的通道不能再发送数据,但可以继续接收数据,直到通道为空。从已关闭的空通道接收数据会得到零值。
- 缓冲通道: 可以创建带缓冲的通道,例如 ch := make(chan int, 10)。缓冲通道允许在没有接收者的情况下,发送一定数量的数据。当缓冲区满时,发送操作仍然会阻塞。

















