读取非缓冲通道

一分耕耘，一分收获！既然打开了这篇文章《读取非缓冲通道》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我试图理解非缓冲通道，所以我编写了一个小应用程序，它迭代用户输入数组，执行一些工作，将信息放在非缓冲通道上，然后读取它。但是，我无法从频道中读取内容。 这是我的代码

toprocess := os.args[1:]

var wg sync.waitgroup
results := make(chan string)
errs := make(chan error)

for _, t := range toprocess {
    wg.add(1)
    go worker(t, "text", results, errs, &wg)
}


go func() {
    for err := range errs {
        if err != nil {
            fmt.println(err)
        }
    }
}()


go func() {
    for res := range results {
        fmt.println(res)
    }
}()

关于非缓冲通道，我不明白什么？我想我应该在上面放置信息，并从中读取另一个 go 例程。

编辑：使用两个 goroutine 解决了问题，但当出现错误时它仍然给我以下信息：

open /users/roosingh/go/src/github.com/nonbuff/files/22.txt: no such file or directory
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [semacquire]:
sync.runtime_semacquire(0xc42001416c)
    /usr/local/cellar/go/1.10.2/libexec/src/runtime/sema.go:56 +0x39
sync.(*waitgroup).wait(0xc420014160)
    /usr/local/cellar/go/1.10.2/libexec/src/sync/waitgroup.go:129 +0x72
main.main()
    /users/roosingh/go/src/github.com/nonbuff/main.go:39 +0x207

goroutine 6 [chan receive]:
main.main.func1(0xc4200780c0)
    /users/roosingh/go/src/github.com/nonbuff/main.go:25 +0x41
created by main.main
    /users/roosingh/go/src/github.com/nonbuff/main.go:24 +0x1d4

goroutine 7 [chan receive]:
main.main.func2(0xc420078060)
    /users/roosingh/go/src/github.com/nonbuff/main.go:34 +0xb2
created by main.main
    /users/roosingh/go/src/github.com/nonbuff/main.go:33 +0x1f6

这样就可以打印出错误信息了。 我的工人代码如下；

func Worker(fn string, text string, results chan string, errs chan error, wg *sync.WaitGroup) {
    file, err := os.Open(fn)
    if err != nil {
        errs <- err
        return
    }
    defer func() {
        file.Close()
        wg.Done()
    }()

    reader := bufio.NewReader(file)


    for {
        var buffer bytes.Buffer

        var l []byte
        var isPrefix bool
        for {
            l, isPrefix, err = reader.ReadLine()
            buffer.Write(l)

            if !isPrefix {
                break
            }

            if err != nil {
                errs <- err
                return

            }
        }

        if err == io.EOF {
            return
        }

        line := buffer.String()

        results <- fmt. Sprintf("%s, %s", line, text)

    }

    if err != io.EOF {
        errs <- err
        return
    }

    return
}

解决方案

对于无缓冲通道，你似乎理解这个概念，这意味着它用于在 goroutine 之间传递消息，但不能保存任何消息。因此，对无缓冲通道的写入将阻塞，直到另一个 goroutine 从该通道读取数据，而从通道读取将阻塞，直到另一个 goroutine 写入该通道。

在你的例子中，你似乎想在同一个 goroutine 中同时读取 2 个通道。由于通道的工作方式，您无法在非封闭通道上进行范围，并在另一个通道上的相同 goroutine 范围内进一步向下。除非第一个通道关闭，否则您将无法到达第二个范围。

但是，这并不意味着不可能！这就是 select 语句的用武之地。

select 语句允许您有选择地从多个通道读取，这意味着它将读取第一个有可供读取内容的通道。

考虑到这一点，您可以将 for 与 select 结合使用，并以这种方式重写您的例程：

go func() {
    for {
        select {
            case err := <- errs: // you got an error
                fmt.println(err) 
            case res := <- results: // you got a result
                fmt.println(res)
        }
    }
}()

此外，您在这里不需要等待组，因为您知道要启动多少个工作人员，您可以只计算得到的错误和结果数量，并在达到工作人员数量时停止。

示例：

go func() {
    var i int
    for {
        select {
            case err := <- errs: // you got an error
                fmt.Println(err)
                i++
            case res := <- results: // you got a result
                fmt.Println(res)
                i++
        }
        // all our workers are done
        if i == len(toProcess) {
            return 
        }
    }
}()

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~