如何在Go中实现并发调用并保留列表顺序？

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《如何在Go中实现并发调用并保留列表顺序？》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

为您提供背景信息，

变量 elementinput 是动态的。我不知道它的确切长度。 可以是 10、5 等。

*元素通道类型是结构体

我的示例正在运行。但我的问题是这个实现仍然是同步的，因为我正在等待通道返回，以便我可以将其附加到我的结果

请帮助我如何并发调用 getelements() 函数并保留 elementinput 中定义的顺序（基于索引）

elementInput := []string{FB_FRIENDS, BEAUTY_USERS, FITNESS_USERS, COMEDY_USERS}

wg.Add(len(elementInput))

for _, v := range elementInput {
    //create channel
    channel := make(chan *Element)
    //concurrent call
    go GetElements(ctx, page, channel)
    //Preserve the order

    var elementRes = *<-channel
    if len(elementRes.List) > 0 {
        el = append(el, elementRes)
    }

}

wg.Wait()

正确答案

您的实现不是并发的。

每次子例程调用后您等待结果的原因，就是使这个串行

下面是与您的流程类似的示例实现

• 调用并发调用函数的 concurreny 方法
• 之后我们循环并收集上述每个调用的响应
• 主子程序休眠2秒

使用运行代码进行演示 -> Sample Application

func main() {
    Concurrency()
    time.Sleep(2000)
}

func response(greeter string, channel chan *string) {
    reply := fmt.Sprintf("hello %s", greeter)
    channel <- &reply
}


func Concurrency() {
    events := []string{"ALICE", "BOB"}
    channels := make([]chan *string, 0)

    // start concurrently 
    for _, event := range events {
        channel := make(chan *string)
        go response(event, channel)
        channels = append(channels, channel)
    }

    // collect response
    response := make([]string, len(channels))

    for i := 0; i < len(channels); i++ {
        response[i] = *<-channels[i]
    }
   // print response 
    log.Printf("channel response %v", response)
}

到这里，我们也就讲完了《如何在Go中实现并发调用并保留列表顺序？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！