
正如摘要所述,Go语言中的通道(channel)可以被形象地理解为消息队列,而
通道与
通道是Go语言中用于协程(goroutine)间通信的重要机制。
-
发送数据到通道:channel
当
立即学习“go语言免费学习笔记(深入)”;
package main import "fmt" func main() { ch := make(chan int) go func() { ch <- 10 // 将 10 发送到通道 ch }() value := <-ch // 从通道 ch 接收数据 fmt.Println(value) // 输出: 10 }在这个例子中,首先创建了一个整数类型的通道 ch。然后,在一个新的协程中,将整数 10 发送到通道 ch。主协程则从通道 ch 接收数据,并将其赋值给变量 value,最终打印出 10。
-
从通道接收数据:value :=
易通企业网站系统CmsEasy7.0.2.20190101下载易通企业网站系统 别名CmsEasy 是国内唯一免费微信+手机端+微网站+手机短信+在线销售+多语言网站组合的企业营销管理平台,易通企业网站系统也称易通企业网站程序,是易通公司开发中国首套免费提供企业网站模板的营销型企业网站管理系统,系统前台生成html、完全符合SEO、同时有在线客服、潜在客户跟踪、便捷企业网站模板制作、搜索引擎推广等功能的企业网站系统。
当
package main import "fmt" import "time" func main() { ch := make(chan string, 2) // 创建一个带缓冲的通道 ch <- "Hello" ch <- "World" fmt.Println(<-ch) // 输出: Hello fmt.Println(<-ch) // 输出: World // 以下代码会阻塞,因为通道已经关闭且没有更多数据 go func() { time.Sleep(time.Second * 2) close(ch) }() // 使用 range 循环从通道接收数据,直到通道关闭 for v := range ch { fmt.Println(v) } }在这个例子中,创建了一个带有缓冲区的字符串类型的通道 ch。首先向通道发送了 "Hello" 和 "World" 两个字符串。然后,通过
利用无缓冲通道实现同步
无缓冲通道在发送和接收操作之间提供了一种同步机制。当一个协程尝试向一个无缓冲通道发送数据时,它会阻塞,直到另一个协程从该通道接收数据。同样,当一个协程尝试从一个无缓冲通道接收数据时,它也会阻塞,直到另一个协程向该通道发送数据。
这种特性可以用来实现类似Java中的 "wait/notify" 操作。一个协程可以阻塞等待接收一个信号,而另一个协程则可以发送该信号,从而唤醒等待的协程。信号的内容本身并不重要,重要的是信号的发送和接收所产生的同步效果。
package main
import (
"fmt"
"time"
)
func main() {
done := make(chan bool) // 创建一个无缓冲通道
go func() {
// 模拟一些耗时操作
time.Sleep(time.Second * 2)
fmt.Println("Worker finished")
done <- true // 发送信号,通知主协程任务完成
}()
fmt.Println("Waiting for worker...")
<-done // 阻塞等待信号
fmt.Println("Done!")
}在这个例子中,done 通道用于主协程和工作协程之间的同步。工作协程在完成任务后,向 done 通道发送一个 true 值,表示任务已完成。主协程则阻塞等待从 done 通道接收数据,直到工作协程发送信号后才继续执行。
注意事项与总结
- 死锁: 如果所有协程都在等待某个通道的操作,而没有任何协程执行发送或接收操作,就会发生死锁。Go运行时会自动检测死锁并抛出错误。
- 关闭通道: 可以使用 close(channel) 关闭一个通道。关闭的通道不能再发送数据,但可以继续接收数据,直到通道为空。从已关闭的空通道接收数据会得到零值。
- 带缓冲通道: 带缓冲通道允许在没有接收者的情况下发送多个值,直到缓冲区满。这可以提高程序的并发性能,但同时也需要注意缓冲区的大小和数据的一致性。
总之,








