go - 这是 goroutine 开销的一个更好的代码

Question

我想让 Reader.Read 与 channel 通信并发。所以我做了两种运行方式

1:

type ReturnRead struct {
    n   int
    err error
}

type ReadGoSt struct {
    Returnc <-chan ReturnRead
    Nextc chan struct{}
}

func (st *ReadGoSt) Close() {
    defer func() {
        recover()
    }()
    close(st.Next)
}

func ReadGo(r io.Reader, b []byte) *ReadGoSt {
    returnc := make(chan ReturnRead)
    nextc := make(chan bool)

    go func() {
        for range nextc {
            n, err := r.Read(b)
            returnc <- ReturnRead{n, err}
            if err != nil {
                return
            }
        }
    }()

    return &ReadGoSt{returnc, nextc}
}

2:

func ReadGo(r io.Reader, b []byte) <-chan ReturnRead {
    returnc := make(chan ReturnRead)
    go func() {
        n, err := r.Read(b)
        returnc <- ReturnRead{n, err}
    }()
    return returnc
}

我认为代码 2 产生了太多开销

哪个代码更好？ 1？ 2?

Answer 1

代码 1 更好，而且可能更快。代码 2 只会读取一次。但我认为这两种解决方案都不是最好的。你应该循环读取并只发回读取的字节。

类似于:http://play.golang.org/p/zRPXOtdgWD