登录
首页 >  Golang >  Go问答

解释一下创建“reloadCh chan chan error”等频道的含义

来源:stackoverflow

时间:2024-03-23 15:09:30 372浏览 收藏

创建 `reloadCh chan chan error` 通道表示一个错误通道的通道。在 Go 语言中,通道是一种通信机制,它允许并发 goroutine 之间安全地传递数据。使用通道通道的一个常见应用是获取请求的响应或错误,如 Prometheus 导出器的情况。通过使用通道通道,可以灵活地选择将响应或错误传送到特定位置,而不是使用同一通道发送请求和接收响应。

问题内容

我是golang新手,开始写一些基于prometheus client-go的monitor exporters,发现promethues的源码中有这样的channel var定义的代码

reloadch     chan chan error

并使用实例化它

reloadch:    make(chan chan error)

像往常一样,可以使用

定义一个通道
reloadCh     chan error

为什么这里有额外的 chan


解决方案


chan chan error 是错误通道的通道。使用通道通道的常见应用之一是获取请求的响应或错误(这实际上是您正在查看的普罗米修斯导出器的情况)。使用渠道的原因是它允许您选择要将答案传达到的位置(与使用相同的渠道发送请求和接收响应相反)。

示例:

package main

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

func main() {

    requestChan := make(chan chan error)

    // Starting the service goroutine
    go goroutine(requestChan)

    // Send 5 requests and collect errors
    for i := 0; i < 5; i++ {
        fmt.Printf("Request %v\n", i+1)

        // Make channel that will be used to communicate error back to main
        errorChan := make(chan error)

        requestChan <- errorChan

        err := <-errorChan
        fmt.Printf("Erro received: %v\n\n", err)

        time.Sleep(1 * time.Second)

    }
}

func goroutine(requestChan <-chan chan error) {

    for {
        select {
        case errChan := <-requestChan:
            fmt.Println("Got request from requestChan")
            errChan <- someOperation()
        }
    }
}

// someOperation that will sometimes return nil error and sometimes it will return error
func someOperation() error {

    if rand.Intn(10) > 5 {
        return nil
    }

    return errors.New("error for someOperation")
}

go playground 上运行它。

sameer ajmani 在 Advanced Go Concurrency Patterns 演讲中对此概念给出了很好的解释。

以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持golang学习网!更多关于Golang的相关知识,也可关注golang学习网公众号。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>