本篇文章为大家展示了Channel 怎么在Golang中使用,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
创新互联建站网站建设提供从项目策划、软件开发,软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务,主营业务为网站建设、网站设计,app软件定制开发以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。创新互联建站深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!channel 是干什么的
意义:channel 是用来通信的
实际上:(数据拷贝了一份,并通过 channel 传递,本质就是个队列)
channel 应该用在什么地方
核心:需要通信的地方
例如以下场景:
通知广播
交换数据
显式同步
并发控制
...
记住!channel 不是用来实现锁机制的,虽然有些地方可以用它来实现类似读写锁,保护临界区的功能,但不要这么用!
channel 用例实现
超时控制
// 利用 time.After 实现 func main() { done := do() select { case <-done: // logic case <-time.After(3 * time.Second): // timeout } } func do() <-chan struct{} { done := make(chan struct{}) go func() { // do something // ... done <- struct{}{} }() return done }
取最快的结果
比较常见的一个场景是重试,第一个请求在指定超时时间内没有返回结果,这时重试第二次,取两次中最快返回的结果使用。
超时控制在上面有,下面代码部分就简单实现调用多次了。
func main() { ret := make(chan string, 3) for i := 0; i < cap(ret); i++ { go call(ret) } fmt.Println(<-ret) } func call(ret chan<- string) { // do something // ... ret <- "result" }
限制大并发数
// 大并发数为 2 limits := make(chan struct{}, 2) for i := 0; i < 10; i++ { go func() { // 缓冲区满了就会阻塞在这 limits <- struct{}{} do() <-limits }() }
for...range 优先
for ... range c { do } 这种写法相当于 if _, ok := <-c; ok { do }
func main() { c := make(chan int, 20) go func() { for i := 0; i < 10; i++ { c <- i } close(c) }() // 当 c 被关闭后,取完里面的元素就会跳出循环 for x := range c { fmt.Println(x) } }
多个 goroutine 同步响应
利用 close 广播
func main() { c := make(chan struct{}) for i := 0; i < 5; i++ { go do(c) } close(c) } func do(c <-chan struct{}) { // 会阻塞直到收到 close <-c fmt.Println("hello") }
非阻塞的 select
select 本身是阻塞的,当所有分支都不满足就会一直阻塞,如果想不阻塞,那么一个什么都不干的 default 分支是最好的选择
select { case <-done: return default: }
for{select{}} 终止
尽量不要用 break label 形式,而是把终止循环的条件放到 for 条件里来实现
for ok { select { case ch <- 0: case <-done: ok = false } }
channel 特性
基础特性
操作 | 值为 nil 的 channel | 被关闭的 channel | 正常的 channel |
---|---|---|---|
close | panic | panic | 成功关闭 |
c<- | 永远阻塞 | panic | 阻塞或成功发送 |
<-c | 永远阻塞 | 永远不阻塞 | 阻塞或成功接收 |
happens-before 特性
无缓冲时,接收 happens-before 发送
任何情况下,发送 happens-before 接收
close happens-before 接收
上述内容就是Channel 怎么在Golang中使用,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联成都网站设计公司行业资讯频道。
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。