Go语言通道之无缓冲通道

作者:奋斗的大橙子 时间:2024-04-25 15:25:57 

一、通道是什么?

其实无论是原子函数还是共享锁都是通过共享内存的方式进行的同步、效率一般不高,而Go语言中则使用了通道,它是一种通过传递信息的方式进行数据同步,通过发送和接收需要共享的资源,在goroutine 之间做同步。可以把通道看作是Goroutine之间的桥梁。

例1:创建一个通道

// 无缓冲的整型通道
unbuffered := make(chan int)
// 有缓冲的字符串通道
buffered := make(chan string, 10)

通道分为有缓冲和无缓冲的通道。

创建一个Channel的关键点:1.使用make创建 2.使用chan来告诉make我要创建的是通道 3.要告诉通道我要建立什么类型的通道。

例2:向通道发送值和接受值

// 有缓冲的字符串通道
buffered := make(chan string, 10)
// 通过通道发送一个字符串
buffered <- "Gopher"
// 从通道接收一个字符串
value := <-buffered

这个例子中创建了一个string类型的Channel,并向通道内传递了一个&ldquo;Gopher&rdquo;字符串,这里是通过<-进行传入的,然后通过<-这个方式把值放到value当中。

这里我的理解 <-就好比是一个赋值符号,无论是把值传递到Channel中,还是把Channel中的值传出来,都是将右边的值给左边

二、通道的种类

由上面的例如1,可以看到Channel也是有多种的,分为无缓冲通道和有缓冲通道,下面就简单总结一下两种类型的通道。

1.无缓冲通道

无缓冲的通道(unbuffered channel)是指在接收前没有能力保存任何值的通道。这种类型的通道要求发送goroutine 和接收goroutine 同时准备好,才能完成发送和接收操作。

Go语言通道之无缓冲通道

上面的图很好的解释了通道和Goroutine的关系

  • 1.左右两个goroutine都没有将手放到通道中。

  • 2.左边的Goroutine将手放到了通道中,模拟了将数据放入通道,此时goroutine会被锁住

  • 3.右边的Goroutine也将手放到了通道中,模拟了从通道中取出数据,同样进入了通道也会被锁住

  • 4.两者通过通道执行数据的交换

  • 5.交换完成

  • 6.两者将手从通道中拿出,模拟了被锁住的goroutine被释放

下面这个程序,模拟了两个人打网球,很好的模拟了两个协程间通过channel进行数据交换

package ChannelDemo

import (
"fmt"
"math/rand"
"sync"
"time"
)

var wg sync.WaitGroup

func init() {
   rand.Seed(time.Now().UnixNano())
}

func PlayTennis() {
   court := make(chan int)
   wg.Add(2)
   //启动了两个协程,一个纳达尔一个德约科维奇
   go player("纳达尔", court)
   go player("德约科维奇", court)

//将1放到通道中,模拟开球
   court <- 1
   wg.Wait()
}

func player(name string, court chan int) {
   defer wg.Done()
   for {
       // 将数据从通道中取出
       ball, ok := <-court
       if !ok {
           fmt.Printf("选手 %s 胜利\n", name)
           return
       }

//获取一个随机值,如果可以整除13,就让一个人没有击中,进而关闭整个通道
       n := rand.Intn(100)
       if n%13 == 0 {
           fmt.Printf("选手 %s 没接到\n", name)
           close(court)
           return
       }
       //如果击中球,就将击球的数量+1,放回通道中
       fmt.Printf("选手 %s 击中 %d\n", name, ball)
       ball++
       court <- ball
   }
}

执行结果(每次会有变化):

选手 纳达尔 击中 1
选手 德约科维奇 击中 2
选手 纳达尔 击中 3
选手 德约科维奇 击中 4
选手 纳达尔 击中 5
选手 德约科维奇 击中 6
选手 纳达尔 击中 7
选手 德约科维奇 击中 8
选手 纳达尔 没接到
选手 德约科维奇 胜利

ok 标志是否为false。如果这个值是false,表示通道已经被关闭,游戏结束。

下面这个例子,模拟里一个接力赛,也就是协程之间的传递的另一种形式

package ChannelDemo

import (
   "fmt"
   "sync"
   "time"
)

var runnerWg sync.WaitGroup

func Running() {
   //创建一个“接力棒”,也就是通道
   baton := make(chan int)
   runnerWg.Add(1)
   //创建第一个跑步走
   go Runner(baton)
   //开始跑
   baton <- 1
   runnerWg.Wait()
}

func Runner(baton chan int) {
   var newRunner int

//选手接过接力棒
   runner := <-baton
   fmt.Printf("第 %d 选手接棒 \n", runner)

//如果不是第四名选手,那么说明比赛还在继续
   if runner != 4 {
       //创建一名新选手
       newRunner = runner + 1
       fmt.Printf("第 %d 准备接棒 \n", newRunner)
       go Runner(baton)
   }

//模拟跑步
   time.Sleep(100 * time.Millisecond)
   //如果第四名跑完了,就结束
   if runner == 4 {
       fmt.Printf("第 %d 结束赛跑 \n", runner)
       runnerWg.Done()
       return
   }

fmt.Printf("第 %d 选手和第 %d 选手交换了接力棒 \n",
       runner,
       newRunner)

//选手递出接力棒
   baton <- newRunner
}

运行结果:

第 1 名选手接棒
第 2 名选手准备接棒
第 1 名选手将接力棒递给第 2 名选手
第 2 名选手接棒
第 3 名选手准备接棒
第 2 名选手将接力棒递给第 3 名选手
第 3 名选手接棒
第 4 名选手准备接棒
第 3 名选手将接力棒递给第 4 名选手
第 4 名选手接棒
第 4 名选手冲线,比赛结束 

三、无缓冲通道小结

我在看例子的过程中,其实遇到的问题在于,我没有理解goroutine是怎么进行交换的,我以为是goroutine有一个集合一样的结构在通道外面等待取数据,这样就存在我刚拿完再那的情况。就像下面这个图显示一样

Go语言通道之无缓冲通道

但是实际情况应该像下面

Go语言通道之无缓冲通道

Go1写入通道锁住的Go1、Go2读出进入通道锁住Go2,只有Go1写完Go2取完才能释放,但是像上面第一个例子代码,读出之后马上就写入,所以对于这样的协程其实一直是锁住的状态。两个协程就通过这种方式进行数据的传递。

来源:https://www.cnblogs.com/dcz2015/p/10383881.html

标签:Go,Golang,无缓冲,通道
0
投稿

猜你喜欢

  • Spring boot 和Vue开发中CORS跨域问题解决

    2024-04-28 09:32:54
  • bootstrap自定义样式之bootstrap实现侧边导航栏功能

    2023-09-06 20:41:36
  • python3 shelve模块的详解

    2022-12-08 19:41:37
  • MSSQL2005数据附加失败报错3456解决办法

    2012-11-30 19:56:59
  • Numpy创建NumPy矩阵的简单实现

    2022-08-22 15:08:25
  • Python实现提取给定网页内的所有链接

    2022-03-29 19:01:11
  • 正确理解python迭代器与生成器

    2022-09-14 22:55:57
  • 详解go-admin在线开发平台学习(安装、配置、启动)

    2023-08-26 15:27:31
  • Python logging自定义字段输出及打印颜色

    2023-09-03 17:04:25
  • 合并网页中的多个script引用实现思路及代码

    2023-06-29 09:02:19
  • Python selenium模拟手动操作实现无人值守刷积分功能

    2021-07-30 23:54:08
  • python 读取以空格分开的文件操作

    2022-09-08 05:33:21
  • Django框架中方法的访问和查找

    2022-07-23 16:31:35
  • Python3连接Mysql8.0遇到的问题及处理步骤

    2024-01-20 13:06:46
  • python距离测量的方法

    2022-12-05 18:27:45
  • Python Web框架Flask中使用百度云存储BCS实例

    2023-09-14 21:53:44
  • Python函数式编程指南(四):生成器详解

    2023-08-23 05:50:02
  • 深入了解vue-router原理并实现一个小demo

    2024-04-30 10:25:31
  • 让ThinkPHP支持大小写url地址访问的方法

    2023-11-17 02:28:37
  • Python实现识别手写数字 Python图片读入与处理

    2022-07-14 17:48:10
  • asp之家 网络编程 m.aspxhome.com