[golang] go中如何监听一组channels

深藏阁楼爱情的钟 2022-09-06 14:23 81阅读 0赞

# go中如何监听一组channels #

## reflect.Select ##

func Select(cases []SelectCase) (chosen int, recv Value, recvOK bool)

cases := make([]reflect.SelectCase, len(chans))
    for i, ch := range chans {
        
        cases[i] = reflect.SelectCase{
        Dir: reflect.SelectRecv, Chan: reflect.ValueOf(ch)}
    }
    chosen, value, ok := reflect.Select(cases)
    // ok will be true if the channel has not been closed.
    ch := chans[chosen]
    msg := value.String()

## “aggregate” channel ##

agg := make(chan string)
    for _, ch := range chans {
        
      go func(c chan string) {
        
        for msg := range c {
        
          agg <- msg
        }
      }(ch)
    }
    
    select {
        
    case msg <- agg:
        fmt.Println("received ", msg)
    }

## benchmark ##

...
    BenchmarkReflectSelect         1    5265109013 ns/op
    BenchmarkGoSelect             20      81911344 ns/op
    ok      command-line-arguments  9.463s

refs : [https://stackoverflow.com/questions/19992334/how-to-listen-to-n-channels-dynamic-select-statement][https_stackoverflow.com_questions_19992334_how-to-listen-to-n-channels-dynamic-select-statement]

[https_stackoverflow.com_questions_19992334_how-to-listen-to-n-channels-dynamic-select-statement]: https://stackoverflow.com/questions/19992334/how-to-listen-to-n-channels-dynamic-select-statement

发表评论取消回复

表情：

评论列表（有 0 条评论，81人围观）

还没有评论，来说两句吧...

相关阅读

相关【Golang】（一）Go语言简介

目录一、什么是Go语言二、Go语言的优势三、Go语言的版本四、Go语言的应用领域五、使用Go的大型互联网公司 --------------------

落日映苍穹つ/ 2024年03月24日 14:54/ 0 赞/ 42 阅读

相关 Golang中channel

声明一个管道 ch:=make(chan int ,10)//声明一个管道遍历管道 //注意，如果需要遍历管道的内容，需要先将管道进行关闭，如果不关闭管

太过爱你忘了你带给我的痛/ 2023年01月06日 14:54/ 0 赞/ 105 阅读

相关 golang channel 12

1.启动设置运行线程数 func main() { //环境变量位置 root := runtime.GOROOT()

青旅半醒/ 2022年12月10日 07:27/ 0 赞/ 145 阅读

相关 Go中的Channel通讯

runtime包介绍（图片来自Go语言中文网） ![图片来自GO语言中文网][GO] 一些较为重要的函数介绍 func NumCPU() int

心已赠人/ 2022年10月29日 05:21/ 0 赞/ 126 阅读

相关 golang mysql 超时_golang channel 超时如何处理

个人理解的channel超时处理思路分享，若有错误或者不足，请联系我:qq 869329877 package main import "time" import "fm

川长思鸟来/ 2022年10月27日 00:26/ 0 赞/ 216 阅读

相关 [golang] go中如何监听一组channels

go中如何监听一组channels reflect.Select func Select(cases []SelectCase) (chosen int,

深藏阁楼爱情的钟/ 2022年09月06日 14:23/ 0 赞/ 82 阅读

相关 golang之Channel

Channel是Go中的一个核心类型，可以将其看成一个管道，通过它并发单元就可以发送或者接收数据进行通信（communication）。 `Do not communicat

心已赠人/ 2022年05月30日 08:58/ 0 赞/ 210 阅读

相关 Golang中Channel的实现原理

CSP模型要想理解 channel 要先知道 CSP 模型。CSP 是 Communicating Sequential Process 的简称，中文可以叫做

痛定思痛。/ 2022年03月16日 00:19/ 0 赞/ 174 阅读

相关 golang(一)初识go

go简介 go语言诞生自2006年，于2009年发布并开源，2012年出现了第一个正式版本。近些年招聘中，go语言算是个小众岗位，只有少数大厂有招聘需求，如阿里，百度，京东等

旧城等待，/ 2022年02月27日 10:54/ 0 赞/ 167 阅读

相关 Go：channel

一、channel 在 Go 语言里，不仅可以使用原子函数和互斥锁来保证对共享资源的安全访问以及消除竞争状态，还可以使用 channel，通过发送和接收需要共享的资源，在

左手的ㄟ右手/ 2021年09月20日 09:16/ 0 赞/ 364 阅读