同时遍历两个集合

Question

在 Go 中，同时遍历 2 个集合的最佳方法是什么？

在我的程序中，我有一个函数创建两个数组，另一个函数需要同时迭代它们（在每次迭代中访问两个数组中的第 I 个元素）。

如果我只有一个输入，我会在第一个函数中创建一个通道（而不是数组），并使用范围循环从各种 goroutine 对其进行迭代。

在这种情况下，是否有比创建索引通道并使用它来访问数组更简单的解决方案？

func main() {
    // Prepare two arrays.
    arrA := [12]int{1, 1, 2, 3, 5, 8, 13, 21, 34, 55, 89, 144}
    arrB := arrA

    // Create a channel with the indexes.
    c := make(chan int, len(arrA))
    for i := range arrA {
        c <- i
    }
    close(c)

    poolSize := 3
    var wg sync.WaitGroup
    wg.Add(poolSize)

    for i := 1; i <= poolSize; i++ {
        go func() {
            defer wg.Done()
            for j := range c {
                fmt.Printf("%v == %v\n", arrA[j], arrB[j])
            }
        }()
    }

    wg.Wait()
}

Answer 1

围棋有句话

"Don't communicate by sharing memory, share memory by communicating"

基本上可以归结为；

"Don't share state across 2 goroutines, instead pass the values needed between the routines, using channels"

它可能是您简化示例的副产品，但是为什么不传递索引，为什么不能将 arrA 和 arrB 的范围限制在单个 goroutine 中，某种将发送值的生产者或生成器。这些值的接收者可以对它们进行处理，在本例中为相等比较。

type pair struct {
    a, b int
}

c := make(chan pair, len(arrA))
for i := range arrA {
    c <- pair{a: arrA[i], b: arrB[i]}
}
close(c)

poolSize := 3
var wg sync.WaitGroup
wg.Add(poolSize)

for _ := range poolSize {
    go func() {
        defer wg.Done()
        for p := range c {
            fmt.Printf("%v == %v\n", p.a, p.b)
        }
    }
}

这似乎是一个微不足道的小改动，但好处是：

隔离：您将 arrA 和 arrB 的访问器范围限制为单个生产 goroutine，稍后在代码中限制竞争条件/复杂逻辑/错误的范围.
重用：您可以在代码库的其他地方重用使用 chan pair 的代码函数，因为它们不直接访问特定数组中的值，而是通过传递他们需要的所有值。

扩展这个；假设您只需要 arrB 中的值而不关心索引，那么您应该在通道上发送该值，并删除对 pair 类型的需要。

同时遍历两个集合

Iterate through two collections concurrently

arrays

channel

go