使用分块读取来读取 Go 通道

大家好，我们又见面了啊~本文《使用分块读取来读取 Go 通道》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

我是 go 新手，我正在尝试编写一个具有两种类型的 goroutine 的程序，一些将写入通道，一些将从该通道读取。

我想对其进行设置，以便从通道读取的 goroutine 将以两个块的形式读取，而编写器 goroutine 将一个接一个地写入。像这样的事情：

n := 20
ch := make(chan struct{}, 2)

// writer goroutines
for i := 0; i < n*2; i++ {
    go func() {
        ch <- struct{}{}
    }()
}

// reader goroutines
for i := 0; i < n; i++ {
    go func() {
        <- ch
        <- ch
    }()
}

我希望我的 writer goroutine 继续向我的通道添加元素，直到通道已满，之后我希望我的 reader goroutine 之一处理通道中的两个元素并立即清除它。基本上，读取器 goroutine 必须等待通道已满才能清除它。

不用说我上面的实现会有竞争条件，并且不是最好的方法。我该如何解决这个问题？我不确定如何让我的阅读器 goroutine 一次读取多个内容并同时避免竞争问题。我愿意使用 go 的其他功能来代替通道。

正确答案

len(ch) - 将返回通道缓冲区中排队（未读）的元素数量。您可以使用此功能在消费前确保通道已满。

另一方面，你必须让你的主例程等待 reader 和 writer goroutine 完成。您可以使用 sync.WaitGroup 来执行此操作

参考号：sync.WaitGroup example

以上就是《使用分块读取来读取 Go 通道》的详细内容，更多关于的资料请关注golang学习网公众号！