Go语言并发编程-Channel通信_2

Channel通信

Channel概述

不要通过共享内存的方式进行通信,而是应该通过通信的方式共享内存

这是Go语言最核心的设计模式之一。

在很多主流的编程语言中,多个线程传递数据的方式一般都是共享内存,而Go语言中多Goroutine通信的主要方案是Channel。Go语言也可以使用共享内存的方式支持Goroutine通信。

image.png

Go语言实现了CSP通信模式,CSP是Communicating Sequential Processes的缩写,通信顺序进程。Goroutine和Channel分别对应CSP中的实体和传递信息的媒介。CSP是Tony Hoare于1977年提出。

Channel提供可接收和发送特定类型值的用于并发函数(Goroutine)通信的数据类型,是满足FIFO(先进先出)原则的队列类型,先进先出不仅体现在数据类型上,也体现在操作上:

  • channel类型的元素是先进先出的,先发送到channel的value会先被receive

  • 先向Channel发送数据的Goroutine会先执行

  • 先从Channel接收数据的Goroutine会先执行

如图:

image.png

Channel操作语法

  • 一个关键字

    • chan

    • chan <-

    • <- chan

  • 两个函数

    • make

    • close

  • 一个语句

    • 发送语句 ch <- expression

  • 一个操作符

    • 接收操作符 <- ch

Channel类型

channel是Go语言中的数据类型,类型声明如下:

 ChannelType = ( "chan" | "chan" "<-" | "<-" "chan" ) ElementType .

其中:

  • chan channel类型关键字

  • <- 操作符,用于Channel收发,定义Channel类型时,用于表示Channel的方向:

    • 默认是双向,可收可发。还可以定义为定向的,仅收仅发。

    • chan<- 仅发送Channel

    • <-chan 仅接收Channel

  • ElementType Channel中元素类型

可见,Channel类型是用于接收或发送特定类型元素的Go数据类型。

示例:

 chan intchan struct{}chan<- int<-chan int

初始化Channel值

内建函数make()可用于初始化Channel值。支持两个参数:

 make(ChannelType, Capacity)

其中:

  • ChannelType是channel类型

  • Capacity是缓冲容量。可以省略或为0,表示无缓冲Channel

channel是引用类型,类似于map和slice。

示例:

 ch := make(chan int)var ch = make(chan int)ch := make(chan int, 10)ch := make(<-chan int)ch := make(chan<- int, 10)

未使用make()初始化的channel为nil。nil channel不能执行收发通信操作,例如:

 var ch chan int

ch就是nil channel。

Send语句和接收操作符

  • Send语句用于向Channel发送值

  • 接收操作符用于从Channel中接收值

Send语句语法:

 SendStmt = Channel "<-" Expression .Channel  = Expression .
 ch <- Expressionch <- 42ch <- f()

接收操作符语法:

 <-chv1 := <-ch // 声明v = <-ch // 赋值f(<-ch) // 函数调用<-strobe // 等待接收

关闭channel

内置函数close()用于关闭channel。

关闭Channel的意思是记录该Channel不能再被发送任何元素了,而不是销毁该Channel的意思。也就意味着关闭的Channel是可以继续接收值的。因此:

  • 向已关闭的Channel发送回引发runtime panic

  • 关闭nil Channel会引发runtime panic

  • 不能关闭仅接收Channel

  • 不能关闭已经关闭的Channel,否则会引发runtime panic

当从已关闭的Channel接收时:

  • 可以接收关闭前发送的全部值

  • 若没有已发送的值会返回类型的零值,不会被阻塞

使用接收操作符的多值返回结构,可以判断Channel是否已经关闭:

var x, ok = <-ch
x, ok := <-ch
  • ok为true,channel未关闭

  • ok为false,channel已关闭

for range channel

for语句的range子句可以持续地从Channel中接收元素,语法如下:

for e := range ch {// e是ch中元素值
}

持续接收操作与接收操作<-行为一致:

  • 若ch为nil channel会阻塞

  • 若ch没有已发送元素会阻塞

for会持续执行到channel被关闭,关闭后,若channel中存在已发送元素,for会全部读取完毕。

示例:

func ChannelFor() {// 一,初始化部分数据ch := make(chan int) // 无缓冲的channelwg := sync.WaitGroup{}// 二,持续发送wg.Add(1)go func() {defer wg.Done()for i := 0; i < 5; i++ {// random send valuech <- rand.Intn(10)}// 关闭close(ch)}()// 三,持续接收,for rangewg.Add(1)go func() {defer wg.Done()// 持续接收for e := range ch {println("received from ch, element is ", e)}}()wg.Wait()
}

缓冲与无冲 channel

Channel区别于是否存在缓冲区,分为:

  • 缓冲Channel,make(chan T, cap),cap是大于0的值。

  • 无缓冲Channel, make(chan T), make(chan T, 0)

无缓冲channel

image.png

也称为同步Channel,只有当发送方和接收方都准备就绪时,通信才会成功。

同步操作示例:

func ChannelSync() {// 初始化数据ch := make(chan int)wg := sync.WaitGroup{}// 间隔发送wg.Add(1)go func() {defer wg.Done()for i := 0; i < 5; i++ {ch <- iprintln("Send ", i, ".\tNow:", time.Now().Format("15:04:05.999999999"))// 间隔时间time.Sleep(1 * time.Second)}close(ch)}()// 间隔接收wg.Add(1)go func() {defer wg.Done()for v := range ch {println("Received ", v, ".\tNow:", time.Now().Format("15:04:05.999999999"))// 间隔时间,注意与send的间隔时间不同time.Sleep(3 * time.Second)}}()wg.Wait()
}

代码中,采用同步channel,使用两个goroutine完成发送和接收。每次发送和接收的时间间隔不同。我们分别打印发送和接收的值和时间。注意结果:

  • 发送和接收时间一致

  • 间隔以长的为准,可见发送和接收操作为同步操作

同步Channel适合在gotoutine间做同步信号!

缓冲Channel

image.png

缓冲Channel也称为异步Channel,接收和发送方不用等待双方就绪即可成功。缓冲Channel会存在一个容量为cap的缓冲空间。当使用缓冲Channel通信时,接收和发送操作是在操作Channel的Buffer:

  • 接收时,从缓冲中接收元素,只要缓冲不为空,不会阻塞。反之,缓冲为空,会阻塞,goroutine挂起

  • 发送时,向缓冲中发送元素,只要缓冲未满,不会阻塞。反之,缓冲满了,会阻塞,goroutine挂起

是典型的队列操作。

缓冲channel操作示例:

func ChannelASync() {// 初始化数据ch := make(chan int, 5)wg := sync.WaitGroup{}// 间隔发送wg.Add(1)go func() {defer wg.Done()for i := 0; i < 5; i++ {ch <- iprintln("Send ", i, ".\tNow:", time.Now().Format("15:04:05.999999999"))// 间隔时间time.Sleep(1 * time.Second)}}()// 间隔接收wg.Add(1)go func() {defer wg.Done()for v := range ch {println("Received ", v, ".\tNow:", time.Now().Format("15:04:05.999999999"))// 间隔时间,注意与send的间隔时间不同time.Sleep(3 * time.Second)}}()wg.Wait()
}

代码中,与同步channel一致,只是采用了容量为5的缓冲channel,使用两个goroutine完成发送和接收。每次发送和接收的时间间隔不同。我们分别打印发送和接收的值和时间。注意结果:

  • 发送和接收时间不同

  • 发送和接收操作不会阻塞,可见发送和接收操作为异步操作

缓冲channel非常适合做goroutine的数据通信了。

长度和容量,len()和cap()

内置函数 len() 和 cap() 可以分别获取:

  • len()长度,缓冲中元素个数。

  • cap()容量,缓冲的总大小。cap()返回0,意味着是无缓冲通道

单向Channel

image.png

单向Channel,指的是仅支持接收或仅支持发送操作的Channel。语法上:

  • chan<- T 仅发送Channel

  • <-chan T 仅接收Channel

单向Channel的意义在于约束Channel的使用方式。

仅使用单向Channel通常没有实际意义,单向Channel最典型的使用方式是:

使用单向通道约束双向通道的操作。

语法上来说,就是我们会将双向Channel转换为单向Channel来使用。典型使用在函数参数或返回值类型中。

示例代码:

func ChannelDirectional() {// 初始化数据ch := make(chan int)wg := &sync.WaitGroup{}// send and receivewg.Add(2)go setElement(ch, 42, wg)go getElement(ch, wg)wg.Wait()
}// only receive channel
func getElement(ch <-chan int, wg *sync.WaitGroup) {defer wg.Done()println("received from ch, element is ", <-ch)
}// only send channel
func setElement(ch chan<- int, v int, wg *sync.WaitGroup) {defer wg.Done()ch <- vprintln("send to ch, element is ", v)
}

函数getElement和setElement,分别使用了单向的接收和发送channel,在语义上表示只能接收和只能发送操作,同时程序上限定了操作。

典型的单向Channel的标准库例子:

// signal.Notify()
func Notify(c chan<- os.Signal, sig ...os.Signal)// time.After
func After(d Duration) <-chan Time

以上两个示例分别展示了单向Channel作为函数参数和函数返回值的语法。

Channel结构

Channel定义结构

image.png

Channel的结构定义为 runtime.hchan

// GOROOT/src/runtime/chan.go
type hchan struct {qcount   uint           // 元素个数。len()dataqsiz uint           // 缓冲队列的长度。cap()buf      unsafe.Pointer // 缓冲队列指针,无缓冲队列为nilelemsize uint16 // 元素大小closed   uint32elemtype *_type // 元素类型sendx    uint   // send indexrecvx    uint   // receive indexrecvq    waitq  // list of recv waiterssendq    waitq  // list of send waiters// lock protects all fields in hchan, as well as several// fields in sudogs blocked on this channel.//// Do not change another G's status while holding this lock// (in particular, do not ready a G), as this can deadlock// with stack shrinking.lock mutex
}

其中:

  • 存储空间分为channel和channel.buf两块

  • channel上记录channel的属性,长度、容量、元素类型、元素大小,接收发送索引、接收发送等待队列

  • channel.buf为elemtype类型的array

  • 若为无缓冲channel,不分配channel.buf空间

  • make()初始化的核心操作就是分配内存空间

缓冲数组

image.png

image.png

缓冲为数组结构,channel记录发送和接收元素的索引:

 sendx    uint   // 发送索引recvx    uint   // 接收索引

缓冲数组是循环使用的,也就是若数组的最后一个元素存储了元素,那么下一次会尝试存储在第一个元素位置。

Channel与Goroutine的关系

image.png

Channel记录两个属性,由于记录等待接收和发送的goroutine队列:

recvq    waitq  // 等待接收goroutine队列
sendq    waitq  // 等待发送goroutine队列

当基于某channel的接收或发送的goroutine无法理解执行时,也就是需要阻塞时,会被记录到Channel的等待队列中。当channel可以完成相应的接收或发送操作时,从等待队列中唤醒goroutine进行操作。

其中等待队列是 runtime.waitq 类型,是一个双向链表结构,具体的某个链表节点存在两个指针,指向前后节点:

// GOROOT/src/runtime/chan.go
type waitq struct {first *sudoglast  *sudog
}

其中 *sudog 可以理解为一个挂起的goroutine。

初始化channel流程

make()初始化channel时,会根据是否存在缓冲,选择:

  • 存在缓冲,为channel和buffer分别分配内存,同时channel.buf指向buffer地址

  • 不存在缓冲,仅为channel分配内存,channel.buf为nil。

  • 初始化channel中其他属性

image.png

向channel发送流程

语句 ch <- element 向channel发送元素时,大体的执行流程如下:

  • 直接发送:当channel存在等待接受者时,channel.recvq,直接将元素拷贝给等待接受者,并唤醒等待接受者goroutine将其放在M的runnext位置,下次调度立即执行

  • 直接写缓冲区,当缓冲区存在空间时,将发送元素直接写入缓冲区,调整channel.sendx的位置

  • 阻塞发送,当缓冲区已满或无缓冲区时,发送goroutine进入channel.sendq队列,转为阻塞状态,等待其他goroutine从channel中接收元素,进而唤醒发送goroutine

image.png

从channel接收流程

操作符 <- ch 从channel中接收元素,大体流程如下:

  • 当存在等待发送者时,channel.sendq

    • 若无缓冲区,直接将元素从发送者拷贝到接受者,并唤醒发送者gorutine,进入runnext下次调度执行

    • 若存在缓冲区,此时缓冲区是满的,从缓冲区获取元素,并将等待发送者发送元素拷贝到缓冲区,唤醒发送者goroutine。调整channel的recvx和sendx索引位置

  • 当缓冲区有元素时(无等待发送者),直接从缓冲区读取元素

  • 如果缓冲区不存在或缓冲区没有元素时,接收者goroutine进入阻塞状态,进入channel.recvq接受者队列,等待发送者发送数据唤醒。

image.png

关闭channel流程

close(ch)关闭channel,主要工作是:

  • 取消channel关联的sendq和recvq队列

  • 调度阻塞在sendq和recvq中的goroutine

select 语句

select 语句能够从多个可读或者可写的Channel中选择一个继续执行 ,若没有Channel发生读写操作,select 会一直阻塞当前Goroutine。

image.png

select语法

SelectStmt = "select" "{" { CommClause } "}" .
CommClause = CommCase ":" StatementList .
CommCase   = "case" ( SendStmt | RecvStmt ) | "default" .
RecvStmt   = [ ExpressionList "=" | IdentifierList ":=" ] RecvExpr .
RecvExpr   = Expression .

语法结构与 switch 类似,但case都要涉及channel操作,示例:

func SelectStmt() {// 声明需要的变量var a [4]intvar c1, c2, c3, c4 = make(chan int), make(chan int), make(chan int), make(chan int)var i1, i2 int// 用于操作channel的goroutinego func() {c1 <- 10}()go func() {<-c2}()go func() {close(c3)}()go func() {c4 <- 40}()// 用于select的goroutinego func() {select {case i1 = <-c1:println("received ", i1, " from c1")case c2 <- i2:println("sent ", i2, " to c2")case i3, ok := <-c3:if ok {println("received ", i3, " from c3")} else {println("c3 is closed")}case a[f()] = <-c4:println("received ", a[f()], " from c4")default:println("no communication")}}()// 简单sleep测试time.Sleep(100 * time.Millisecond)
}func f() int {print("f() was run")return 2
}

测试:

func TestSelectStmt(t *testing.T) {for i := 0; i < 10; i++ {println(i, ":")SelectStmt()}
}

执行流程

image.png

select语句的执行分为几个步骤:

  1. 对于全部的 case,receive操作的channel操作数、send语句的channel和右表达式在进入select语句时只会基于源码顺序计算一次。计算结果是一组要从中接收或者发送到的channel,以及要发送的相应值。RecvStmt的左侧带有短变量声明或赋值的表达式尚未计算。

  2. 如果一个或多个通信可以继续,通过伪随机数选择其中一个继续执行。否则,如果存在default case,选择该case。如果没有default case,select 语句会阻塞直到至少一个通信操作可以继续。

  3. 除非选择了default case,那么相应的通信操作会被执行。

  4. 如果选择的case是带有短变量声明或赋值的RecvStmt,左侧表达式会被计算,并分配接收的值(或多个值)。

  5. 执行所选择的case的语句列表。

for + select

select 匹配到可操作的case或者是defaultcase后,就执行完毕了。实操时,我们通常需要持续监听某些channel的操作,因此典型的select使用会配合for完成。

例如:持续从某个ch内获取数据

func SelectFor() {ch := make(chan int)// send to channelgo func() {for {// 模拟演示数据来自于随机数// 实操时,数据可以来自各种I/O,例如网络、缓存、数据库等ch <- rand.Intn(100)time.Sleep(200 * time.Millisecond)}}()// select receive from channelgo func() {for {select {case v := <-ch:println("received value: ", v)}}}()time.Sleep(3 * time.Second)
}

阻塞select

以下典型的情况会直接导致阻塞goroutine:

  • 不存在任何case的

  • case监听都是nil channel

示例:

func SelectBlock() {// 空select阻塞println("before select")select {}println("after select")// nil select阻塞var ch chan intgo func() {ch <- 1024}()println("before select")select {case <-ch:case ch <- 42:}println("after select")
}

go test 测试时,会一直阻塞。若上面的代码出现在常规执行流程中,会导致 deadlock。

nil channel的case

nil channel 不能读写,因此通过将channel设置为nil,可以控制某个case不再被执行。

例如,3秒后,不再接受ch的数据:

func SelectNilChannel() {ch := make(chan int)// 写channelgo func() {// 随机写入intrand.Seed(time.Now().Unix())for {ch <- rand.Intn(10)time.Sleep(400 * time.Millisecond)}}()// 读channelgo func() {sum := 0t := time.After(3 * time.Second)for {select {case v := <-ch:println("received value: ", v)sum += vcase <-t:// 将channel设置为nil,不再读写ch = nilprintln("ch was set nil, sum is ", sum)}}}()// sleep 5 秒time.Sleep(5 * time.Second)
}

带有default的select,非阻塞收发

当select语句存在default case时:

  • 若没有可操作的channel,会执行default case

  • 若有可操作的channel,会执行对应的case

这样select语句不会进入block状态,称之为非阻塞(non-block)的收发(channel 的接收和发送)。

示例:多人猜数字游戏,我们在乎是否有人猜中数字:

func SelectNonBlock() {// 初始化数据counter := 10 // 参与人数max := 20     // [0, 19] // 最大范围rand.Seed(time.Now().UnixMilli())answer := rand.Intn(max) // 随机答案println("The answer is ", answer)println("------------------------------")// 正确答案channelbingoCh := make(chan int, counter)// wgwg := sync.WaitGroup{}wg.Add(counter)for i := 0; i < counter; i++ {// 每个goroutine代表一个猜数字的人go func() {defer wg.Done()result := rand.Intn(max)println("someone guess ", result)// 答案争取,写入channelif result == answer {bingoCh <- result}}()}wg.Wait()println("------------------------------")// 是否有人发送了正确结果// 可以是0或多个人// 核心问题是是否有人猜中,而不是几个人select {case result := <-bingoCh:println("some one hint the answer ", result)default:println("no one hint the answer")}
}

特别的情况是存在两个case,其中一个是default,另一个是channel case,那么go的优化器会优化内部这个select。内部会以if结构完成处理。因为这种情况,不用考虑随机性的问题。类似于:

select {case result := <-bingoCh:println("some one hint the answer ", result)default:// 非阻塞的保证,存在default caseprintln("no one hint the answer")
}// 优化伪代码
if selectnbrecv(bingoCh) {println("some one hint the answer ", result)
} else {println("no one hint the answer")
}

Race模式

image.png

Race模式,典型的并发执行模式之一,多路同时操作资源,哪路先操作成功,优先使用,同时放弃其他路的等待。简而言之,从多个操作中选择一个最快的。核心工作:

  • 选择最快的

  • 停止其他未完成的

示例代码,示例从多个查询器同时读取数据,使用最先反返回结果的,其他查询器结束:

func SelectRace() {// 一,初始化数据// 模拟查询结果,需要与具体的querier建立联系type Rows struct {// 数据字段// 索引标识Index int}// 模拟的querier数量const QuerierNum = 8// 用于通信的channel,数据,停止信号ch := make(chan Rows, 1)stopChs := [QuerierNum]chan struct{}{}for i := range stopChs {stopChs[i] = make(chan struct{})}// wg,randwg := sync.WaitGroup{}rand.Seed(time.Now().UnixMilli())// 二,模拟querier查询,每个查询持续不同的时间wg.Add(QuerierNum)for i := 0; i < QuerierNum; i++ {// 每一个 queriergo func(i int) {defer wg.Done()// 模拟执行时间randD := rand.Intn(1000)println("querier ", i, " start fetch data, need duration is ", randD, " ms.")// 查询结果的channelchRst := make(chan Rows, 1)// 执行查询工作go func() {// 模拟时长time.Sleep(time.Duration(randD) * time.Millisecond)chRst <- Rows{Index: i,}}()// 监听查询结果和停止信号channelselect {// 查询结果case rows := <-chRst:println("querier ", i, " get result.")// 保证没有其他结果写入,才写入结果if len(ch) == 0 {ch <- rows}// stop信号case <-stopChs[i]:println("querier ", i, " is stopping.")return}}(i)}// 三,等待第一个查询结果的反馈wg.Add(1)go func() {defer wg.Done()// 等待ch中传递的结果select {// 等待第一个查询结果case rows := <-ch:println("get first result from ", rows.Index, ". stop other querier.")// 循环结构,全部通知querier结束for i := range stopChs {// 当前返回结果的goroutine不需要了,因为已经结束if i == rows.Index {continue}stopChs[i] <- struct{}{}}// 计划一个超时时间case <-time.After(5 * time.Second):println("all querier timeout.")// 循环结构,全部通知querier结束for i := range stopChs {stopChs[i] <- struct{}{}}}}()wg.Wait()
}

其中核心点:

  • 获取了结果,通知结束

  • 通过多个无缓冲channel通知goroutine结束

  • 通过缓冲channel传递结果

执行结果示例:

querier  2  start fetch data, Need duration is  674  ms.
querier  6  start fetch data, Need duration is  695  ms.
querier  1  start fetch data, Need duration is  484  ms.
querier  4  start fetch data, Need duration is  544  ms.
querier  0  start fetch data, Need duration is  101  ms.
querier  7  start fetch data, Need duration is  233  ms.
querier  5  start fetch data, Need duration is  721  ms.
querier  3  start fetch data, Need duration is  727  ms.
querier  0  get result.
get first result from  0 . stop other querier.
querier  7  is stopping.
querier  2  is stopping.
querier  4  is stopping.
querier  6  is stopping.
querier  5  is stopping.
querier  1  is stopping.
querier  3  is stopping.

All 模式

image.png

Race模式是多个Goroutine获取相同的结果,优先使用快速响应的。

而All模式是多个Goroutine分别获取结果的各个部分,全部获取完毕后,组合成完整的数据,要保证全部的Goroutine都响应后,继续执行。

示例代码,核心逻辑:

  • 一个整体内容Content,分为三个goroutine分别处理subject、tags、views三个部分

  • 3个goroutine要全部执行完毕,数据才会整体获取

  • 不会一直等待,设置超时时间。

本例中,使用具体的每个goroutine的标识方案来识别goroutine。对比Race方案使用的是索引号的方案来识别goroutine。

判定是否全部结束的方案,也是基于具体的标志key。

其中某次执行结果为:

start fetch  tags  data, need duration is  396  ms.
start fetch  views  data, need duration is  693  ms.
start fetch  subject  data, need duration is  597  ms.
querier  tags  get result.
received some part  tags
querier timeout. Content is incomplete.
querier  subject  is stopping.
querier  views  is stopping.
received content  { [go Goroutine Channel select] 0 }

无缓冲Channel+关闭作典型同步信号

基于:

  • 无缓冲Channel是同步的

  • closed 的channel是可以接收内容的

以上两点原因,经常使用关闭无缓冲channel的方案来作为信号传递使用。前提是,信号纯粹是信号,没有其他含义,比如关闭时间等。

示例代码:

func SelectChannelCloseSignal() {wg := sync.WaitGroup{}// 定义无缓冲channel// 作为一个终止信号使用(啥功能的信号都可以,信号本身不分功能)ch := make(chan struct{})// goroutine,用来close, 表示
发出信号wg.Add(1)go func() {defer wg.Done()time.Sleep(2 * time.Second)fmt.Println("发出信号, close(ch)")close(ch)}()// goroutine,接收ch,表示接收信号wg.Add(1)go func() {defer wg.Done()// 先正常处理,等待ch的信号到来for {select {case <-ch:fmt.Println("收到信号, <-ch")returndefault:}// 正常的业务逻辑fmt.Println("业务逻辑处理中....")time.Sleep(300 * time.Millise
cond)}}()wg.Wait()
}// ====
> go test -run TestSelectChannelCloseSignal
业务逻辑处理中....
业务逻辑处理中....
业务逻辑处理中....
业务逻辑处理中....
业务逻辑处理中....
业务逻辑处理中....
业务逻辑处理中....
发出信号, close(ch)
收到信号, <-ch
PASS
ok      goConcurrency   2.168s

signal.Notify 信号通知监控

系统信号也是通过channel与应用程序交互,例如典型的 ctrl+c 中断程序, os.Interrupt,若不监控系统信号,ctrl+c后程序会直接终止,而如果监控了信号,那么可以在ctrl+c后,执行一系列的关闭处理,例如:

func SelectSignal() {// 一:模拟一段长时间运行的goroutinego func() {for {fmt.Println(time.Now().Format(".15.04.05.000"))time.Sleep(300 * time.Millisecond)}}()// 要求主goroutine等待上面的goroutine,方案:// 1. wg.Wait()// 2. time.Sleep()// 3. select{}// 持久阻塞//select {}// 二,监控系统的中断信号,interrupt// 1 创建channel,用于传递信号chSignal := make(chan os.Signal, 1)// 2 设置该channel可以监控哪些信号signal.Notify(chSignal, os.Interrupt)//signal.Notify(chSignal, os.Interrupt, os.Kill)//signal.Notify(chSignal) // 全部类型的信号都可以使用该channel// 3 监控channelselect {case <-chSignal:fmt.Println("received os signal: Interrupt")}
}

定时器与断续器,Timer&Ticker

Timer&Ticker是Go标准包time中定义的类型,通过Channel与程序进行通信。

time包中两个与Channel紧密关联的结构:

// 定时器
time.Timer
// 断续器
time.Ticker
  • 定时器Timer类似于一次性闹钟

  • 断续器Ticker类似于重复性闹钟,也成循环定时器

无论是一次性还是重复性计时器,都是通过Channel与应用程序交互的。我们通过监控Timer和Ticker返回的Channel,来确定是否到时的需求。

定时器

image.png

使用语法:

// time.NewTimer
func NewTimer(d Duration) *Timer

创建定时器。参数是Duration时间。返回为 *Timer*Timer.C是用来接收到期通知的单向Channel。

type Timer struct {C <-chan Time
}

因此我们只要可从 *Timer.C上接收数据,就意味着定时器时间到。接收到的元素是 time.Time 类型数据,为到时时间。

示例:

func TimerA() {t := time.NewTimer(time.Second)println("Set the timer, \ttime is ", time.Now().String())now := <-t.Cprintln("The time is up, time is ", now.String())
}

Timer除了C之外,还有两个方法:

// 停止计时器
// 返回值bool类型,返回false,表示该定时器早已经停止,返回true表示由本次调用停止
func (t *Timer) Stop() bool// 重置定时器
// 返回值bool类型,返回false,表示该定时器早已经停止,返回true表示由本次调用重置
func (t *Timer) Reset(d Duration) bool

使用这两个方法,可以完整定时器的业务逻辑。

示例代码,简单的猜数字游戏,共猜5次,每次有超时时间3秒钟:

func TimerB() {ch := make(chan int)// 写channelgo func() {// 随机写入intfor {ch <- rand.Intn(10)time.Sleep(400 * time.Millisecond)}}()// 每局时间t := time.NewTimer(time.Second * 3)hint, miss := 0, 0// 统计结果,共玩5次for i := 0; i < 5; i++ {guess:for {select {case v := <-ch:println("guess value: ", v)if v == 4 {println("Bingo! some one hint the answer.")// 新游戏,重置定时器t.Reset(time.Second * 3)hint++break guess}case <-t.C:println("The time is up, no one hint.")miss++// 重新创建定时器t = time.NewTimer(time.Second * 3)break guess}}}println("Game Over! Hint ", hint, ", Miss ", miss)
}

代码在猜中或者时间到时,要重置或新建定时器。

如果不需要定时器的关闭和重置操作,可以使用函数:

func After(d Duration) <-chan Time

直接返回定时器到期的通知Channel。

func TimerC() {ch := time.After(time.Second)println("Set the timer, \ttime is ", time.Now().String())now := <-chprintln("The time is up, time is ", now.String())
}

如果希望在定时器到期时执行特定函数,可以使用如下函数:

func AfterFunc(d Duration, f func()) *Timer

该函数返回*Timer用于控制定时器,例如Stop或Reset.

断续器

image.png

也叫循环定时器。

使用语法:

func NewTicker(d Duration) *Ticker

创建断续器。参数是Duration时间。返回为 *Ticker*Ticker.C是用来接收到期通知的单向Channel。

type Ticker struct {C <-chan Time // The channel on which the ticks are delivered.
}

因此我们只要可从 *Ticker.C上接收数据,就意味着断续器时间到。接收到的元素是 time.Time 类型数据,为到时时间。当接收到到期时间后,间隔下一个Duration还会再次接收到到期时间。

*Ticker也有方法:

// 停止断续器
func (t *Ticker) Stop()
// 重置断续器间隔时间
func (t *Ticker) Reset(d Duration)

示例:

func TickerA() {// 断续器ticker := time.NewTicker(time.Second)// 定时器timer := time.After(5 * time.Second)
loop: // 持续心跳for now := range ticker.C {println("now is ", now.String())// heart beatprintln("http.Get(\"/ping\")")// 非阻塞读timer,到时结束断续器select {case <-timer:ticker.Stop()break loopdefault:}}
}

代码模拟了一个心跳程序,间隔1秒,发送ping操作。整体到时,运行结束。

小结

Channel的分类

  • nil channel

  • 缓冲Channel

  • 无缓冲Channel

  • 单向Channel

Channel的操作

  • 初始化,make(channel type[, cap])

  • 发送,ch <- expression

  • 接收, v, ok := <- ch

  • 遍历接收,for e := range ch {}

  • 关闭, close(ch)

select语句

  • channel的多路复用

  • 执行第一个可以操作channel的case

  • 若同时多个channel可操作随机选择case避免饥饿case的出现

  • 增加default case可以达到非阻塞channel操作的目的

  • 经常配合for select使用循环多路监听

  • 典型的多路模式有:Race和All

timer和ticker

  • 定时器,到时执行一次,可以在到时前,重置或提前结束

  • 断续器,配置间隔重复执行,重复定时器,可以重置间隔时间和提前结束

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/47653.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

JavaEE:Lombok工具包的使用以及EditStarter插件的安装

Lombok是一个Java工具库&#xff0c;通过添加注解的方式&#xff0c;简化Java的开发。 目录 1、引入依赖 2、使用 3、原理解释 4、更多使用 5、更快捷的引入依赖 1、引入依赖 <dependency><groupId>org.projectlombok</groupId><artifactId>lomb…

pdf提取其中一页怎么操作?提取PDF其中一页的方法

pdf提取其中一页怎么操作&#xff1f;需要从一个PDF文件中提取特定页码的操作通常是在处理文档时常见的需求。这种操作允许用户选择性地获取所需的信息&#xff0c;而不必操作整个文档。通过选择性提取页面&#xff0c;你可以更高效地管理和利用PDF文件的内容&#xff0c;无论是…

Linux编辑器——vim的使用

目录 vim的基本概念 命令模式 底行模式 插入模式 注释和取消注释 普通用户进行sudo提权 vim配置问题 vim的基本概念 一般使用的vim有三种模式&#xff1a; 命令模式 底行模式和插入模式&#xff0c;可以进行转换&#xff1b; vim filename 打开vim&#xff0c;进入的…

ffmpeg ffplay.c 源码分析

1 ffplay.c的意义 ffplay.c是FFmpeg源码⾃带的播放器&#xff0c;调⽤FFmpeg和SDL API实现⼀个⾮常有⽤的播放器。 例如哔哩哔哩著名开源项⽬ijkplayer也是基于ffplay.c进⾏⼆次开发。 ffplay实现了播放器的主体功能&#xff0c;掌握其原理对于我们独⽴开发播放器⾮常有帮助…

npm install时报错 reason: certificate has expired

在VS code中导入新项目&#xff0c;执行npm install时报错&#xff1a; npm warn old lockfile Could not fetch metadata for antv/g3.4.10 FetchError: request to https://registry.npm.taobao.org/antv%2fg failed, reason: certificate has expirednpm warn old lockfile …

UI设计中的响应式布局策略:让您的界面在各种设备上都表现出色

UI界面设计它是人与机器之间交互的媒介&#xff0c;也是客户体验的媒介&#xff08;UX&#xff09;一个组成部分。操作界面由两个主要部分组成&#xff1a;视觉设计&#xff08;即传达产品的外观和感觉&#xff09;和交互设计&#xff08;即元素功能和逻辑组织&#xff09;。用…

kubernetes Dashboard搭建 (六)

DashBoard 之前在kubernetes中完成的所有操作都是通过命令行工具kubectl完成的。其实&#xff0c;为了提供更丰富的用户体验&#xff0c;kubernetes还开发了一个基于web的用户界面&#xff08;Dashboard&#xff09; 用户可以使用Dashboard部署容器化的应用&#xff0c;还可以监…

<数据集>木材缺陷检测数据集<目标检测>

数据集格式&#xff1a;VOCYOLO格式 图片数量&#xff1a;4000张 标注数量(xml文件个数)&#xff1a;4000 标注数量(txt文件个数)&#xff1a;4000 标注类别数&#xff1a;8 标注类别名称&#xff1a;[Quartzity,Live_Knot,Marrow,resin,Dead_Knot,knot_with_crack,Knot_m…

Prometheus 监控 Java 应用 JMX Exporter

操作场景 Prometheus 社区开发了 JMX Exporter 用于导出 JVM 的监控指标&#xff0c;以便使用 Prometheus 来采集监控数据。当您的 Java 业务容器化至 Kubernetes 后&#xff0c;可通过本文了解如何使用 Prometheus 与 JMX Exporter 来监控 Java 应用。 JMX Exporter 简介 Ja…

如何在 Puppeteer 中运行无头浏览器?

什么是无头浏览器&#xff1f; 我们都知道&#xff0c;用户界面&#xff08;UI&#xff09;是任何软件中最重要的部分。因此&#xff0c;“无头浏览器”的“无头”部分意味着它们确实缺少一个关键元素&#xff0c;即图形用户界面&#xff08;GUI&#xff09;。 这意味着浏览器…

webrtc QOS方法十三(视频渲染平滑)

一、背景介绍 视频渲染时间的确定需要考虑三方面的因素&#xff1a;网络抖动、网络延时、音视频同步 网络抖动&#xff1a;视频帧在网络上传输&#xff0c;会受到网络抖动的影响&#xff0c;不能收到立刻播放&#xff0c;需要进行适当的平滑 网络延时&#xff1a;一些报文在…

docker 安装并测试(Ubuntu下)

1. 确认安装环境&#xff08;操作系统版本和 CPU 架构&#xff09; 2. 如果有旧版本的 docker 需要进行卸载 使用 docker 命令检查是否已经安装了 docker 如果 docker 已经安装&#xff0c;使用以下命令卸载&#xff1a; apt-get purge docker-ce docker-ce-cli containerd…

力扣3202:找出有效子序列的最大长度||

class Solution { public:int maximumLength(vector<int>& nums, int k) {int res0;for(int m0;m<k;m){//假设子序列两数%k之后的结果为m 相当于枚举vector<int> v(k,0);for(auto num:nums){v[num%k]v[(m-num%kk)%k]1; //知道m之后可以知道需要的子序列当前…

maven内网依赖包编译报错问题的一种解决方法

背景 外网开发时可以连接互联网&#xff0c;所以编译没有什么问题&#xff0c;但是将数据库、代码、maven仓库全部拷贝到内网&#xff0c;搭建内网环境之后&#xff0c;编译失败。 此依赖包的依赖层级图 maven镜像库配置使用拷贝到内网的本地库&#xff0c;配置如下&#xff…

【Linux】Linux环境设置环境变量操作步骤

Linux环境设置环境变量操作步骤 在一些开发过程中本地调试经常需要依赖环境变量的参数&#xff0c;但是怎么设置对小白来说有点困难&#xff0c;今天就介绍下具体的操作步骤&#xff0c;跟着实战去学习&#xff0c;更好的检验自己的技术水平&#xff0c;做技术还是那句话&…

【iOS】——内存对齐

内存对齐是什么 内存对齐指的是数据在内存中的布局方式&#xff0c;它确保每个数据类型的起始地址能够满足该类型对齐的要求。这是因为现代处理器在访问内存时&#xff0c;如果数据的起始地址能够对齐到一定的边界&#xff0c;那么访问速度会更快。这种对齐通常是基于数据类型…

BUUCTF逆向wp [MRCTF2020]Transform

第一步 查壳。该题为64位。 第二步 进入主函数&#xff0c;跟进dword_40F040,它应该与关键字符串有关 分析一下&#xff1a; 初始化和输入 sub_402230(argc, argv, envp); 这行可能是一个初始化函数&#xff0c;用于设置程序环境或处理命令行参数。具体功能不明&#xff0c…

高性能、安全、低碳绿色的趋势下,锐捷网络发布三擎云办公解决方案 3.0

桌面虚拟化作为云时代的主流和热门技术&#xff0c;已经取得了广泛应用。随着生成式 AI 爆炸式发展&#xff0c;CSDN 看到&#xff0c;人工智能正在引发计算、开发、交互三大范式的全面升级&#xff0c;技术开发或将迎来一次全新的科技变革周期&#xff0c;因此 VDI 云桌面随之…

C#语法基础详解(万字总结)

文章目录 **参考书籍&#xff1a;C#7.0 核心技术指南**类型类字段解构器对象初始化器属性表达式属性(只读属性才可以)自动属性属性初始化器 索引器静态构造器nameof运算符 继承类型转换和引用转换as运算符is运算符is与模式变量 虚函数成员抽象类和抽象成员new和重写base关键字构…

Android C++系列:Linux线程(四)线程同步

多个线程同时访问共享数据时可能会冲突,这跟我们前面信号文章所说的可重入性是同样的问题。比如两个线程都要把某个全局变量增加1,这个操作在某平台需要三条指令完成: 从内存读变量值到寄存器;寄存器的值加1;将寄存器的值写回内存假设两个线程在多处理器平台上同时执行这三…