Go语言中如何并发调用GetElements并保持输入列表的顺序？

背景说明 #

变量elementInput是动态的，长度不确定（比如10、5等）。Element是结构体类型，GetElements()通过通道返回该类型的指针。

当前示例代码虽能运行，但实际是同步执行——因为每次发起调用后都要等待通道返回结果，才能追加到结果列表，无法真正并发。

需求：并发调用GetElements()，同时保证最终结果列表的顺序与elementInput的索引顺序一致。

实现方案 #

核心思路是预先创建对应长度的结果切片，每个goroutine完成后将结果写入对应索引的位置，最后统一整理有效结果。同时用WaitGroup等待所有goroutine执行完毕，避免程序提前退出。

修改后的代码如下：

elementInput := []string{FB_FRIENDS, BEAUTY_USERS, FITNESS_USERS, COMEDY_USERS}
// 预先创建对应长度的结果切片，存储每个goroutine的返回值
results := make([]*Element, len(elementInput))
var wg sync.WaitGroup

wg.Add(len(elementInput))
for idx, v := range elementInput {
    // 捕获当前循环索引，避免goroutine引用循环变量的最终值导致索引错乱
    index := idx
    go func(input string) {
        defer wg.Done()
        channel := make(chan *Element)
        GetElements(ctx, page, channel)
        res := <-channel
        // 将结果写入对应索引的位置，保证顺序
        results[index] = res
    }(v)
}

// 等待所有goroutine执行完成
wg.Wait()

// 遍历结果切片，收集List不为空的有效结果
var el []Element
for _, res := range results {
    if res != nil && len(res.List) > 0 {
        el = append(el, *res)
    }
}

关键细节说明 #

• 预先分配结果切片：根据elementInput的长度创建切片，每个goroutine完成后将结果写入对应索引位置，从根源保证输出顺序与输入一致。
• 捕获循环索引：在goroutine外部保存当前循环的idx到index变量，避免goroutine延迟执行时引用循环变量的最终值，导致索引错误。
• WaitGroup正确使用：每个goroutine启动前调用wg.Add()，内部用defer wg.Done()确保无论是否出错都能标记任务完成，最后wg.Wait()等待所有任务结束。
• 统一收集有效结果：所有goroutine完成后再筛选有效数据，彻底避免原代码中同步等待通道返回的问题，真正实现并发执行。

内容的提问来源于stack exchange，提问作者yssachan