golang 协程 (goroutine) 与通道 (channel)

2024-03-08 01:20

本文主要是介绍golang 协程 (goroutine) 与通道 (channel),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

golang的协程和通道,之前就看过了,一直没有很好的理解,所以一直也没记录,今天看书,看到有一个总结的章节,里面记录了一些注意事项,因此写个文档,记录一下,避免以后自己忘了或者是找不见资料

顺便吐槽下公司的业务,自己负责的业务能啥也不知道,开发完了给他们上线了,完事还问你,这个为什么会这样,这不是你要求的吗?UAT的时候业务全程参加,都看过了,没问题才上线,过了一个月尽然能忘得一干二净。

出于性能考虑的建议:
实践经验表明,为了使并行运算获得高于串行运算的效率,在协程内部完成的工作量,必须远远高于协程的创建和相互来回通信的开销。

出于性能考虑建议使用带缓存的通道:
使用带缓存的通道可以很轻易成倍提高它的吞吐量,某些场景其性能可以提高至 10 倍甚至更多。通过调整通道的容量,甚至可以尝试着更进一步的优化其性能。

限制一个通道的数据数量并将它们封装成一个数组:
如果使用通道传递大量单独的数据,那么通道将变成性能瓶颈。然而,将数据块打包封装成数组,在接收端解压数据时,性能可以提高至 10 倍。

现在创建一个带缓存的通道:ch := make(chan type,buf)
(1)如何使用 for 或者 for-range 遍历一个通道:(尽量使用这种或者是跟select配合使用)

这种其实就是一个for循环遍历通道,但是golang的机制,这里会自动监测通道是否关闭,而不需要开发二次判断通道是否关闭
但是这里有个坑需要注意,会有死锁的问题,因为你的通道中没有数据的时候,for range ch 会发生阻塞,但是无法解除阻塞,发生死锁

for v := range ch {// do something with v
}

(2)如何检测一个通道 ch 是否关闭:

//read channel until it closes or error-condition
for {if input, open := <-ch; !open {// 这里!open,就是表示通道已经被关了,break跳出循环,不从通道里面获取数据了break}fmt.Printf("%s", input)
}

(3)如何通过一个通道让主程序等待直到协程完成(信号量模式):如果希望程序一直阻塞,在匿名函数中省略 ch <- 1 即可。

ch := make(chan int) // Allocate a channel.
// Start something in a goroutine; when it completes, signal on the channel.
go func() {// doSomethingch <- 1 // Send a signal; value does not matter.
}()
doSomethingElseForAWhile()
<-ch // Wait for goroutine to finish; discard sent value.
func compute(ch chan int){ch <- someComputation() // when it completes, signal on the channel.
}func main(){ch := make(chan int) 	// allocate a channel.go compute(ch)		// start something in a goroutinesdoSomethingElseForAWhile()result := <- ch
}

(4)通道的工厂模板:以下函数是一个通道工厂,启动一个匿名函数作为协程以生产通道:

func pump() chan int {ch := make(chan int)go func() {for i := 0; ; i++ {ch <- i}}()return ch
}

(5)通道迭代器模板:

func (c *container) Iter () <- chan item {ch := make(chan item)go func () {for i:= 0; i < c.Len(); i++{	// or use a for-range loopch <- c.items[i]}} ()return ch
}
for x := range container.Iter() { ... }

(6)如何限制并发处理请求的数量

package mainconst MAXREQS = 50var sem = make(chan int, MAXREQS)type Request struct {a, b   intreplyc chan int
}func process(r *Request) {// do something
}func handle(r *Request) {sem <- 1 // doesn't matter what we put in itprocess(r)<-sem // one empty place in the buffer: the next request can start
}func server(service chan *Request) {for {request := <-servicego handle(request)}
}func main() {service := make(chan *Request)go server(service)
}

(7)如何在多核CPU上实现并行计算:

func DoAll(){sem := make(chan int, NCPU) // Buffering optional but sensiblefor i := 0; i < NCPU; i++ {go DoPart(sem)}// Drain the channel sem, waiting for NCPU tasks to completefor i := 0; i < NCPU; i++ {<-sem // wait for one task to complete}// All done.
}func DoPart(sem chan int) {// do the part of the computationsem <-1 // signal that this piece is done
}func main() {runtime.GOMAXPROCS(NCPU) // runtime.GOMAXPROCS = NCPUDoAll()
}

(8)如何终止一个协程:runtime.Goexit()

(9)简单的超时模板:

timeout := make(chan bool, 1)
go func() {time.Sleep(1e9) // one second  timeout <- true
}()
select {case <-ch:// a read from ch has occurredcase <-timeout:// the read from ch has timed out
}

(10)如何使用输入通道和输出通道代替锁:

func Worker(in, out chan *Task) {for {t := <-inprocess(t)out <- t}
}

(11)如何在同步调用运行时间过长时将之丢弃:

// 注意缓冲大小设置为 1 是必要的,可以避免协程死锁以及确保超时的通道可以被垃圾回收。
// 此外,需要注意在有多个 case 符合条件时, select 对 case 的选择是伪随机的
// 如果代码稍作修改如下
// 则 select 语句可能不会在定时器超时信号到来时立刻选中 time.After(timeoutNs) 对应的 case
// 因此协程可能不会严格按照定时器设置的时间结束。
ch := make(chan int, 1)
go func() { for { ch <- 1 } } ()
L:
for {select {case <-ch:// do somethingcase <-time.After(timeoutNs):// call timed outbreak L}
}

(12)如何在通道中使用计时器和定时器:定时器 (Timer) 结构体和计时器 (Ticker) 结构体

package mainimport ("fmt""time"
)func main() {tick := time.Tick(1e8)boom := time.After(5e8)for {select {case <-tick:fmt.Println("tick.")case <-boom:fmt.Println("BOOM!")returndefault:fmt.Println("    .")time.Sleep(5e7)}}
}

这篇关于golang 协程 (goroutine) 与通道 (channel)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/785493

相关文章

golang 日志log与logrus示例详解

《golang日志log与logrus示例详解》log是Go语言标准库中一个简单的日志库,本文给大家介绍golang日志log与logrus示例详解,感兴趣的朋友一起看看吧... 目录一、Go 标准库 log 详解1. 功能特点2. 常用函数3. 示例代码4. 优势和局限二、第三方库 logrus 详解1.

Android Kotlin 高阶函数详解及其在协程中的应用小结

《AndroidKotlin高阶函数详解及其在协程中的应用小结》高阶函数是Kotlin中的一个重要特性,它能够将函数作为一等公民(First-ClassCitizen),使得代码更加简洁、灵活和可... 目录1. 引言2. 什么是高阶函数?3. 高阶函数的基础用法3.1 传递函数作为参数3.2 Lambda

Golang中拼接字符串的6种方式性能对比

《Golang中拼接字符串的6种方式性能对比》golang的string类型是不可修改的,对于拼接字符串来说,本质上还是创建一个新的对象将数据放进去,主要有6种拼接方式,下面小编就来为大家详细讲讲吧... 目录拼接方式介绍性能对比测试代码测试结果源码分析golang的string类型是不可修改的,对于拼接字

如何通过Golang的container/list实现LRU缓存算法

《如何通过Golang的container/list实现LRU缓存算法》文章介绍了Go语言中container/list包实现的双向链表,并探讨了如何使用链表实现LRU缓存,LRU缓存通过维护一个双向... 目录力扣:146. LRU 缓存主要结构 List 和 Element常用方法1. 初始化链表2.

Golang基于内存的键值存储缓存库go-cache

《Golang基于内存的键值存储缓存库go-cache》go-cache是一个内存中的key:valuestore/cache库,适用于单机应用程序,本文主要介绍了Golang基于内存的键值存储缓存库... 目录文档安装方法示例1示例2使用注意点优点缺点go-cache 和 Redis 缓存对比1)功能特性

Golang中map缩容的实现

《Golang中map缩容的实现》本文主要介绍了Go语言中map的扩缩容机制,包括grow和hashGrow方法的处理,具有一定的参考价值,感兴趣的可以了解一下... 目录基本分析带来的隐患为什么不支持缩容基本分析在 Go 底层源码 src/runtime/map.go 中,扩缩容的处理方法是 grow

golang获取prometheus数据(prometheus/client_golang包)

《golang获取prometheus数据(prometheus/client_golang包)》本文主要介绍了使用Go语言的prometheus/client_golang包来获取Prometheu... 目录1. 创建链接1.1 语法1.2 完整示例2. 简单查询2.1 语法2.2 完整示例3. 范围值

golang panic 函数用法示例详解

《golangpanic函数用法示例详解》在Go语言中,panic用于触发不可恢复的错误,终止函数执行并逐层向上触发defer,最终若未被recover捕获,程序会崩溃,recover用于在def... 目录1. panic 的作用2. 基本用法3. recover 的使用规则4. 错误处理建议5. 常见错

golang字符串匹配算法解读

《golang字符串匹配算法解读》文章介绍了字符串匹配算法的原理,特别是Knuth-Morris-Pratt(KMP)算法,该算法通过构建模式串的前缀表来减少匹配时的不必要的字符比较,从而提高效率,在... 目录简介KMP实现代码总结简介字符串匹配算法主要用于在一个较长的文本串中查找一个较短的字符串(称为

golang内存对齐的项目实践

《golang内存对齐的项目实践》本文主要介绍了golang内存对齐的项目实践,内存对齐不仅有助于提高内存访问效率,还确保了与硬件接口的兼容性,是Go语言编程中不可忽视的重要优化手段,下面就来介绍一下... 目录一、结构体中的字段顺序与内存对齐二、内存对齐的原理与规则三、调整结构体字段顺序优化内存对齐四、内