内容简介:近最学习了一下Go语言的 goroutine(协程),channel(通道),select,time等相关的知识,这里我通过一个例子来说一下对它们的理解与使用。先来看一个异步任务生产与消费的例子,最后再去细看一些理论知识,这对于一个新手来说可能会更容易理解。这里使用2个goroutine往n大小的通道中模拟任务生产。select中的case哪个可以读取则打印出数据,每隔5秒我们来看一下生产的消息还有多少没有被打印过。
近最学习了一下 Go 语言的 goroutine(协程),channel(通道),select,time等相关的知识,这里我通过一个例子来说一下对它们的理解与使用。
先来看一个异步任务生产与消费的例子,最后再去细看一些理论知识,这对于一个新手来说可能会更容易理解。
一、队列生产与消费的例子
这里使用2个goroutine往n大小的通道中模拟任务生产。select中的case哪个可以读取则打印出数据,每隔5秒我们来看一下生产的消息还有多少没有被打印过。
func main() { var t1 = makeTask("adoJob", 1000) var t2 = makeTask("xs25Job", 500) var tick = time.Tick(time.Second * 5) for { select { case task:=<-t1: log.Println(task) case task:=<-t2: log.Println(task) case <-tick: log.Println(fmt.Sprintf("队列挤压数量t1:%v个,t2:%v个", len(t1), len(t2))) } time.Sleep(time.Second * 1) } } //生产数据 func makeTask(queueName string, n int) chan string { ch := make(chan string, n) go func() { i := 1 for { time.Sleep(time.Millisecond * time.Duration(rand.Intn(2000))) //假设生产任务占用时间 ch <- fmt.Sprintf("%s,生产数据 %d", queueName, i) i++ } }() return ch }
运行后的结果:
2020/01/23 00:25:09 adoJob,生产数据 1 2020/01/23 00:25:10 xs25Job,生产数据 1 2020/01/23 00:25:11 xs25Job,生产数据 2 2020/01/23 00:25:12 adoJob,生产数据 2 2020/01/23 00:25:13 xs25Job,生产数据 3 2020/01/23 00:25:14 队列挤压数量 t1:7个,t2:3个 2020/01/23 00:25:15 adoJob,生产数据 3 2020/01/23 00:25:16 adoJob,生产数据 4 2020/01/23 00:25:17 adoJob,生产数据 5 2020/01/23 00:25:18 adoJob,生产数据 6 2020/01/23 00:25:19 adoJob,生产数据 7 2020/01/23 00:25:20 xs25Job,生产数据 4 2020/01/23 00:25:21 xs25Job,生产数据 5 2020/01/23 00:25:22 adoJob,生产数据 8 2020/01/23 00:25:23 队列挤压数量 t1:10个,t2:9个
以上这段代码我模拟了2个生产端,一个定时任务。
这里先对代码做一个简单的解释:
go func() 开启一个goroutine(协程)
ch := make(chan string, n) 创建一个n个元素缓冲大小的string通道。大于0则属于有缓冲通道。
<- 这个符号表示从通道里读数据或往通道中写数据。通道是先进先出原则。
makeTask("adoJob", 1000) adoJob这个任务,创建一个1000大小的有缓冲通道,开启一个goroutine随机时间往里写数据
makeTask("xs25Job", 500) xs25Job这个任务,创建一个500大小的有缓冲通道,开启一个goroutine随机时间往里写数据
time.Tick(time.Second * 5) 定时任务,每5秒运行一次,我们在这里主要是为了练习,每隔5秒钟有可能执行不到这个case。原因是多个case都满足时随机执行其中一个。
现在我们再使用goroutine与无缓冲通道做一个消费端,将代码再改进一下。
func main() { var t1 = makeTask("adoJob", 1000) var t2 = makeTask("xs25Job", 1000) var allTask []string //因为我想只做一个消费端,将2个生产端生产出来的消费都扔到一起 var tick = time.Tick(time.Second * 5) //每隔一段时间报告队列积压情况 var workerCh = worker() for { var taskInfo string //具体任务 var ch chan<- string if len(allTask) > 0 { taskInfo = allTask[0] //从所有任务中取出每一个 ch = workerCh } select { case task := <-t1: allTask = append(allTask, task) case task := <-t2: allTask = append(allTask, task) case ch <- taskInfo: //任务详情写入到要消费工作中 allTask = allTask[1:] case <-tick: log.Println("队列挤压数量", len(allTask)) } } } //生产数据 func makeTask(queueName string, n int) chan string { ch := make(chan string, n) go func() { i := 1 for { time.Sleep(time.Millisecond * time.Duration(rand.Intn(2000))) //假设生产任务占用时间 ch <- fmt.Sprintf("%s,生产数据 %d", queueName, i) i++ } }() return ch } //消费数据 func worker() chan<- string { ch := make(chan string) //无缓冲通道 go func(tasks chan string) { for t := range tasks { time.Sleep(time.Second * 1) //假设我们每次消费任务需要花费1秒钟 log.Printf("消费任务: %s \n", t) } }(ch) return ch }
运行后的结果:
2020/01/23 00:28:21 消费任务: adoJob,生产数据 1 2020/01/23 00:28:23 消费任务: xs25Job,生产数据 1 2020/01/23 00:28:24 消费任务: adoJob,生产数据 2 2020/01/23 00:28:25 消费任务: xs25Job,生产数据 2 2020/01/23 00:28:25 队列挤压数量 8 2020/01/23 00:28:26 消费任务: adoJob,生产数据 3 2020/01/23 00:28:27 消费任务: adoJob,生产数据 4 2020/01/23 00:28:28 消费任务: adoJob,生产数据 5 2020/01/23 00:28:29 消费任务: xs25Job,生产数据 3 2020/01/23 00:28:30 消费任务: adoJob,生产数据 6 2020/01/23 00:28:30 队列挤压数量 11
我们可以看出因生产速度快,消费速度跟不上,产生了队列挤压。这个代码例子主要是为了练习一下select上面的使用。通过这个例子的实验,对Go语言的goroutine,channel,select有了一个简单的了解。
二、理论知识
看完上面的例子,我们再来看这些枯燥的理论知识会轻松许多
1、goroutine
goroutine 是一种非常轻量级的实现,可在单个进程里执行成千上万的并发任务,它是Go语言并发设计的核心。
goroutine 其实就是线程,但是它比线程更小,十几个 goroutine 可能体现在底层就是五六个线程,而且Go语言内部也实现了goroutine 之间的内存共享, go 关键字就可以创建 goroutine。
将 go 声明放到一个需调用的函数之前,在相同地址空间调用运行这个函数,这样该函数执行时便会作为一个独立的并发线程,这种线程在Go语言中则被称为 goroutine。
如果两个或者多个 goroutine 在没有相互同步的情况下,访问某个共享的资源,比如同时对该资源进行读写时,就会处于相互竞争。可以使用sync.WaitGroup,sync.Mutex相关的包进行处理。
2、channel
go语言提倡使用通信的方法代替共享内存,当一个资源需要在 goroutine 之间共享时,通道在 goroutine 之间架起了一个管道,并提供了确保同步交换数据的机制,channels是goroutine之间的通信机制,一个channels是一个通信机制,它可以让一个goroutine通过它给另一个goroutine发送值信息。
3、select
select 的用法与 switch 语言非常类似,select 有比较多的限制,其中最大的一条限制就是每个 case 语句里必须是一个 IO 操作。 select用来监听和channel有关的IO操作,当 IO 操作发生时,触发相应的动作。如果有一个或多个IO操作可以完成,系统就会随机的选择一个执行。如果都没有完成有defalut分支就会选择defalut分支,如果defalut也没有,那select语句会一直阻塞,直到有一个IO操作才进行。
4、time.Tick
定时任务,调用Tick函数会返回一个时间类型的channel,在调用Tick方法的过程中,必然又创建了goroutine,负责发送数据,唤醒被阻塞的定时任务。定时任务都会加入timersBucket(时间任务桶),关于time.Tick这里先不做太深入的探讨。这里我们每隔5秒会看看一下当前任务数量。
三、总结
在golang的开发中,协程goroutine是go的核心,也是我们最常用的技术。
协程之间要数据共享离不开通道channel的使用。使用channel时注意无缓冲通道,与有缓冲通道的区别。 无缓冲通道保证收发过程同步,有人给你打电话,你接起来与他通话。 有缓冲通道收发过程不需同步,有人给你发短信,你可以过一会看,过一会再回复。
数据共享读写时要注意存在互相竞争问题,这时要考虑加锁。
使用select监听channel的操作要注意多个case条件都满足时会随机触发一个,一个条件都不满足时会一直阻塞。
go中定时任务使用time.Tick而不是使用time.Sleep
四、最后闲谈
今天是2020年春节前的最后一个工作日啦,最近新冠状病毒引起人们的恐慌。全国确诊新型肺炎数字不断上升,武汉连夜宣布全面进入战时状态,暂时关闭离汉通道。春运是人口流动性最频繁的一个周期,希望此次疫情能停止扩散,尽早得到控制。
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- C语言的位操作常见例子
- [译] Go 语言的整洁架构之道 —— 一个使用 gRPC 的 Go 项目整洁架构例子
- gRPC in ASP.NET Core 3.x -- Protocol Buffer, Go语言的例子(上)
- 一个例子了解迁移学习
- oracle审计例子
- 弹性盒模型常见例子
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Flash ActionScript 3.0 动画高级教程
Keith Peters / 苏金国、荆涛 / 人民邮电出版社 / 2010-1 / 65.00元
《Flash ActionScript 3.0 动画高级教程》是介绍Flash 10 ActionScript动画高级技术的经典之作,是作者在这一领域中多年实践经验的结晶。书中不仅涵盖了3D、最新绘图API以及Pixel Bender等Flash 10 ActionScript特性,深入介绍了碰撞检测、转向、寻路等Flash游戏开发技术,还通过实例具体讲解了等角投影和数值积分的基本理论和应用。 ......一起来看看 《Flash ActionScript 3.0 动画高级教程》 这本书的介绍吧!