侧边栏壁纸
博主头像
秋码记录

一个游离于山间之上的Java爱好者 | A Java lover living in the mountains

  • 累计撰写 123 篇文章
  • 累计创建 256 个标签
  • 累计创建 41 个分类

Go 语言中的 Channel(Let's Go 二十九)

Channel 是进程内的通信方式,因此通过 channel 传递对象的过程和调用函数时的参数传递行为比较一致,比如也可以传递指针等。如果需要跨进程通信,我们建议用分布式系统的方法来解决,比如使用 Socket 或者 HTTP 等通信协议。Go 语言对于网络方面也有非常完善的支持。

接上篇,要想在 goroutine 间进行通信,则需通过 Channel 信道传递消息。

Channel 是进程内的通信方式,因此通过 channel 传递对象的过程和调用函数时的参数传递行为比较一致,比如也可以传递指针等。如果需要跨进程通信,我们建议用分布式系统的方法来解决,比如使用 Socket 或者 HTTP 等通信协议。Go 语言对于网络方面也有非常完善的支持。

Channel 是类型相关的,也就是说,一个 Channel 只能传递一种类型的值,这个类型需要在声明 Channel 时指定。如果对 Unix 管道有所了解的话,就不难理解 Channel,可以将其认为是一种类型安全的管道。

var chanVar chan chanType  // 声明 信道  chanVar 信道变量  chanType  信道类型
chanVar = make(chan chanType) //声明后的 信道 须通过 make() 函数进行创建

信道发送数据

使用<-操作符进行发送数据。

chanVar <- value  //chanVar 信道变量  value 发送的数据

注意:发送的数据类型要与 信道变量 的类型一致。

信道接收数据

信道接受数据同样使用<-操作符。

而接收数据又有四种方式。

  • 1、阻塞模式接收数据

    data := <-chanVar
    

执行该语句时将会阻塞,直到接收到数据并赋值给 data 变量。

  • 2、非阻塞式接收数据
data, ok := <-chanVar

data:表示接收到的数据。未接收到数据时,data 为信道类型的零值。

ok:表示是否接收到数据。

非阻塞的信道接收方法可能造成高的 CPU 占用,因此使用非常少。如果需要实现接收超时检测,可以配合 select 和计时器 channel 进行,后续将会讲到。

  • 3、接收任意数据,忽略接收的数据
<-chanVar

阻塞接收数据后,忽略从信道返回的数据。

执行该语句时将会发生阻塞,直到接收到数据,但接收到的数据会被忽略。这个方式实际上只是通过通道在 goroutine 间阻塞收发实现并发同步。

package main

import (
    "fmt"
)

func main() {

    chanVar := make(chan string)

    go func() {
        fmt.Println(" start goroutine")
        chanVar <- "https://qiucode.cn"
        fmt.Println("end goroutine")
    }()

    fmt.Println("out print start")
    <-chanVar
    fmt.Println("out print end")

}

img

代码说明如下:

  • 第 9 行,构建一个同步用的信道。

  • 第 11 行,开启一个匿名函数的并发。

  • 第 13 行,匿名 goroutine 即将结束时,通过信道通知 main 的 goroutine,这一句会一直阻塞直到 main 的 goroutine 接收为止。

  • 第 18 行,开启 goroutine 后,马上通过信道等待匿名 goroutine 结束。

  • 4、循环接收

信道的数据接收可以借用 for range 语句进行多个元素的接收操作.。

for data := range chanVar {

}

信道 chanVar 是可以进行遍历的,遍历的结果就是接收到的数据。数据类型就是信道的数据类型。通过 for 遍历获得的变量只有一个,即上面例子中的 data。

package main

import (
    "fmt"
)

func main() {

    chanVar := make(chan int)

    go func() {
        for i := 0; i < 5; i++ {
            chanVar <- i
        }
    }()

    for data := range chanVar {
        fmt.Println(data)
        if data == 4 {
            break
        }
    }

}

img

当接收到数值 4 时,停止接收。如果继续发送,由于接收 goroutine 已经退出,没有 goroutine 发送到信道,因此运行时将会触发宕机报错。

Go 语言中的并发编程(Let's Go 二十八)
« 上一篇 2022-10-24
Go 语言中的单向 Channel(Let's Go 三十)
下一篇 » 2022-10-29

相关推荐