致命错误发生在尝试实现使用通道的 io.Reader 时

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《致命错误发生在尝试实现使用通道的 io.Reader 时》，这篇文章主要讲到等等知识，如果你对Golang相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

对于这个非常简单的问题，我深表歉意，只是在我们如何实现 io.reader 方面遇到了一些麻烦。

我的最终用例是我正在消耗一个可以随时发送数据的无限流。为了模拟这个，我创建了一个 emitter 来实现 io.reader 和 io.writer。

我同时使用 bufio.scanner 来听读器，同时从 main 向任何侦听器发送值。

演示： https://goplay.space/#ejfe0hyfyrl

func main() {
    wg := &sync.waitgroup{}
    wg.add(1)

    data := newemitter()

    go func() {
        scanner := bufio.newscanner(data)
        for scanner.scan() {
            fmt.println(scanner.text())
        }
        wg.done()
    }()

    data.writestring("foo")
    time.sleep(2 * time.second)
    data.writestring("bar")

    wg.wait()
}

我的emitter

type emitter struct {
    ch chan []byte
}

func (em *emitter) read(b []byte) (int, error) {
    n := copy(b, <-em.ch)
    return n, nil
}

func (em *emitter) write(b []byte) (int, error) {
    em.ch <- b
    return len(b), nil
}

func (em *emitter) writestring(s string) (int, error) {
    return em.write([]byte(s))
}

func newemitter() *emitter {
    return &emitter{
        ch: make(chan []byte),
    }
}

我收到以下错误

fatal error: all goroutines are asleep - deadlock!

解决方案

从 <-em.ch 接收时，emitter.read 中的 goroutine 块。 wg.wait 上的主要 goroutine 块。陷入僵局！

通过向发射器添加 clos​​e() 方法来关闭 em.ch 来修复。当通道关闭时，在emitter.read中返回io.eof。 发送数据完成后关闭发射器。

emitter 还存在其他问题。使用 io.Pipe 将写入器连接到读取器，而不是修复 emitter：

wg := &sync.WaitGroup{}
wg.Add(1)

pr, pw := io.Pipe()

go func() {
    scanner := bufio.NewScanner(pr)
    for scanner.Scan() {
        fmt.Println(scanner.Text())
    }
    wg.Done()
}()

io.WriteString(pw, "foo\n")
time.Sleep(2 * time.Second)
io.WriteString(pw, "bar\n")
pw.Close()

wg.Wait()

Run it on the playground。

今天关于《致命错误发生在尝试实现使用通道的 io.Reader 时》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！