Golang中Channel使用的一点随想

Golang中Channel使用的一点随想

前言(为什么要写这篇文章)

在Golang中,搞同步/并发控制的方法有很多,有channel(管道),WaitGroup(等待线程结束),context(上下文管理),我一直想深入研究一下它们,因为这次开发我遇到了很多比较棘手的问题,我认为万变不离其宗,所以我看了一下他们的源码,然后简单的写了几个Demo,结合了我自己的开发经验,写成此文,做记录的同时,希望可以帮到其他兄弟,未来我还会出context随想,waitgroup随想,一点一点来吧。

什么是channel

首先你要了解两个东西,一个是goroutine,一个是CSP(Communicating Sequential Processes)

goroutine:Go协程,比线程小,内存占用小,Go的主打

CSP:一种模型,并发模型,说白了,就是依赖channel,认为信息的载体更加重要。这里相对来说比较复杂,请大家参考 http://www.usingcsp.com/cspbook.pdf 去学习一个。

那么channel到底是什么呢,其实就是一种在goroutine之间通用的通信方式,这么理解吧,军队每天都看到人守夜,每天都有不同的口号,比如哨兵a,哨兵b进行交接的时候,就要对暗号,我们理解一下,哨兵a,b是两个goroutine,那么口令就是channel,通过channel,我们可以控制哨兵下岗,上岗,巡逻,那么换算到goroutine中,我们就可以控制goroutine启动,停止,这就是channel的牛逼之处。

channel长什么样?(我们怎么定义channel)

channel的定义方法非常简单,利用chan 关键字就可以

1
test := make(chan bool)

这里的make,没有定义缓存值,channel可以定义一个缓存值,例如

1
make(chan int, 100)

这里代表channel 的缓存大小为100,如果不设置缓存值,那么channel没有缓存,在没有通讯的情况下,将被阻塞。

是的,这个就定义好了,现在你就有一个名叫test的bool类型的channel,你可能会问,卧槽,这东西有什么用?行,我马上就举个例子告诉你这玩意儿怎么使。我知道你们大部分都不爱看理论,只爱看解决问题的模型,没问题,我惯你!

来个channel的并发例子

你细分析分析,一般你什么时候会用到goroutine间通信?那不就是一个不够使,多开几个,增加咱们program的效率嘛。是,你可以用 go example() 这种类型,开它十几二十个,但是你怎么知道他们结束了呢?估摸着你写sleep啊,就像

1
2
3
4
5
6
listip := []string{"10.0.9.11","10.0.9.22","10.0.9.33"}
for _, ip := range(listip) {
//假设我们执行一个ping ip 的逻辑
go PingIPWork(ip)
}
time.sleep(time.Second * 5)

这样其实没啥毛病,因为你不加那个sleep,人家估摸着就会一闪而过,你什么消息都收不到,我们这里有三个Ip,相当于你 go PingIPWork(ip)这里执行,外部的主程会直接退出去,人家才不管你搞完没呢,你又没和人家说是吧,所以channel就是干这个的,就是告诉主程,里面还有人呢嘿,别关门!

1
2
3
4
5
6
7
8
9
10
11
12
listip := []string{"10.0.9.11","10.0.9.22","10.0.9.33"}
ch := make(chan struct{})
for _, ip := range listip {
go func(ip string) {
//假设执行一个ping ip的逻辑
go PingIPWork(ip)
ch <- struct{}{}
}(ip)
}
for range ips {
<-ch
}

这里去并发去执行PingIPWork,并且主程会等待所有goroutine完成之后才会彻底退出。发现了没,channel和goroutine一般都是放在一起的。

在for…i range中使用channel

有时候我们需要阻塞range,或者是控制循环不退出,这时候就可以用到channel

1
2
3
4
5
6
7
8
9
10
11
12
13
listip := ["10.0.9.11","10.0.9.22","10.0.9.33"]

//创建channel
forever := make(chan bool)

go func() {
for _, d := range msgs {
log.Printf("Received a message: %s", d)
}
}()

//阻塞,让它不退出
<-forever

在select中使用channel

类似switch的骚操作,一般来说,你给人家整死循环了,你不得负责给人家搞退出,或者说满足必要条件退出

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// 创建 quit channel
quit := make(chan string)
// 启动生产者 goroutine
c := boring("Joe", quit)
// 从生产者 channel 读取结果
for i := rand.Intn(10); i >= 0; i-- { fmt.Println(<-c) }
// 通过 quit channel 通知生产者停止生产
quit <- "Bye!"
fmt.Printf("Joe says: %q\n", <-quit)

select {
case c <- fmt.Sprintf("%s: %d", msg, i):
fmt.Println("work....")
case <-quit:
quit <- "See you!"
return
}

有些时候我们不想等那么久,所以我们需要(timeout)机制

1
2
3
4
5
6
7
8
9
10
11
c1 := make(chan string, 1)
go func() {
time.Sleep(time.Second * 2)
c1 <- "result 1"
}()
select {
case res := <-c1:
fmt.Println(res)
case <-time.After(time.Second * 1):
fmt.Println("timeout 1")
}

关闭一个channel

不用的东西要打包放好,否则你开一大堆channel在那里,搞一大堆panic: send on closed channel很吼么? 随意关闭channel的姿势你也要学到,其实关闭的逻辑也很简单,关键字close

1
2
3
c := make(chan int, 10)
c <- 1
close(c)

这就关掉了,但是这样关不严谨,你还是能拿到c已经发出去的数据,而且还能不断的读到0值,所以一定要换个方法

1
2
3
4
c := make(chan int, 10)
close(c)
i, ok := <-c
fmt.Printf("%d, %t", i, ok)

这样就能判断,当close时,读到的值是零值还是正常值,也就避免了上面出现的那种情况,一直读,一直有。

后记

我感觉我学的还是不够深,我希望我的技术能更进一步,所以我还是要不断学习,我可以的,我会做到的。这里面其实都是些皮毛。。我感觉,我希望未来一定要多学多读多看。哈哈,这篇文章写完了我也要去吃饭了,今天我吃仔肺粉 + 锅盔,我去吃饭啦!有问题给我留言或者邮件吧!

写于2020-05-25 19:36分

打赏
  • 版权声明: 本博客所有文章除特别声明外,著作权归作者所有。转载请注明出处!
  • © 2019-2021 Yemilice lau
  • Powered by Hexo Theme Ayer
  • PV: UV:

觉得帮到你了么?赏我点儿~

支付宝
微信