
在Golang中,goroutine之间传递数据,实现并发编程。理解
通道与
可以将通道视为一个消息队列。
-
发送数据到通道 (Enqueue):
当通道位于
立即学习“go语言免费学习笔记(深入)”;
ch <- data // 将 data 发送到通道 ch
这里,ch 是一个通道,data 是要发送的数据。 这行代码会将 data 放入通道 ch 中。 如果通道已满,则发送操作将会阻塞,直到通道有空闲位置。
-
从通道接收数据 (Dequeue):
8CMS企业网站管理系统 X1.0下载8CMS网站管理系统 (著作权登记号 2009SRBJ3516 ),基于微软 asp + Access 开发,是实用的双模建站系统,应用于企业宣传型网站创建、贸易型网站创建、在线购买商务型网站创建。是中小型企业能够以最低的成本、最少的人力投入、在最短的时间内架设一个功能齐全、性能优异、SEO架构合理的网站平台工具。8CMS的使命是把建设网站最大程度的简化。
当通道位于
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)。缓冲通道允许在没有接收者的情况下,发送一定数量的数据。当缓冲区满时,发送操作仍然会阻塞。









