goroutine，它接受信道接收器并将字符串发送到信道

Question

我试图对goroutines做一个循环，它接受一个接收字符串的通道，每次接收它时，它都应该将值追加到另一个字符串。只有在所有goroutine结束时（goroutine计数应该是传入的列表的长度），代码才应该继续。

func appendToStr(str string, list []string, origin *url.URL) {
    var currProc int32 = 0;
    var maxProc int32 = int32(len(list))

    var strReceiver := make(chan string, len(list))
    for _, item := range list {
        go func() {
            doAsyncAndIncrement(item, strReceiver, &currProc)
            str += <-strReceiver 
        }()
    }

    for {
        if atomic.LoadInt32(&currProc) <= maxProc {
            break;
        }
    }

    // continue on using 'str' which now contains the append values from the 'strReceiver' channel
}

func doAsyncAndIncrement(item string, receiver chan<- string, count *int32) {
    defer atomic.AddInt32(count, 1)

    var val string
    // do something with 'item' and set 'val'...

    receiver <- val
}

Answer 1

代码的一个问题是go例程调用周围的闭包太大。

for _, item := range list {
    go func() {
        doAsyncAndIncrement(item, strReceiver, &currProc)
        str += <-strReceiver 
    }()
}

item的作用域为for循环，而不是goroutine中的匿名函数，因此当您触发N个goroutine时，item变量同时在for循环中更新。要解决这个问题，请将该变量显式地传递给goroutine，以避免使用闭包：

for _, item := range list {
    go func(item string) {
        doAsyncAndIncrement(item, strReceiver, &currProc)
        str += <-strReceiver 
    }(item)
}