在完成时将通道结果添加到队列的更惯用的方法

Question

因此，现在，我只需传递一个指向 Queue 对象的指针（实现并不重要），并在 goroutine 末尾调用 queue.add(result) 来将内容添加到队列中。

我需要同样类型的功能，当然，与简单的队列添加函数调用相比，使用逗号 ok 语法进行循环检查完成在性能方面是不可接受的。

有没有办法做得更好，或者没有？

Answer 1

您的问题实际上有两个部分：如何在 Go 中对数据进行排队，以及如何在不阻塞的情况下使用通道。

对于第一部分，听起来您需要做的不是使用通道将内容添加到队列中，而是使用通道作为队列。例如：

var (
    ch = make(chan int) // You can add an int parameter to this make call to create a buffered channel

    // Do not buffer these channels!
    gFinished = make(chan bool)
    processFinished = make(chan bool)
)
func f() {
    go g()
    for {
        // send values over ch here...
    }
    <-gFinished
    close(ch)
}
func g() {
    // create more expensive objects...
    gFinished <- true
}
func processObjects() {
    for val := range ch {
        // Process each val here
    }
    processFinished <- true
}
func main() {
    go processObjects()
    f()
    <-processFinished
}

至于如何使其更加异步，您可以（如 cthom06 指出的）将第二个整数传递给第二行中的 make 调用，这将使发送操作异步，直到通道缓冲区已满。

编辑：但是（正如 cthom06 也指出的那样），因为你有两个 goroutine 写入通道，所以其中一个必须负责关闭通道。另外，我之前的修订将在 processObjects 完成之前退出。我选择同步 goroutine 的方法是创建更多的通道来传递虚拟值，以确保清理正确完成。这些通道专门是无缓冲的，因此发送是同步进行的。