golang中如何顺序处理并发请求？

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《golang中如何顺序处理并发请求？》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我是 golang 新手，我发现 go 频道非常有趣。我的背景是 javascript，我想在 go 中按顺序处理并发请求，有点像 javascript 中的 promise.all() 。我想要的只是发出一些并发运行的请求，并按照我调用它们的顺序处理返回的数据。

等效的 javascript 代码如下所示：

async function main() {
  // assuming all db calls will return a promise
  const firstuserpromise = firstdbcall().then((res) => res);
  const seconduserpromise = seconddbcall().then((res) => res);
  const thriduserpromise = thriddbcall().then((res) => res);

  const [
    firstuserdata,
    seconduserdata,
    thirduserdata
  ] = await promise.all([firstuserpromise, seconduserpromise, thirduserpromise]);
}

如果您不熟悉 javascript，在上面的代码中我将进行三个同时发生的数据库调用（从第 3 行到第 5 行）。然后我等待他们给出一些答复（从第 7 行到第 10 行）。这段代码的好处是，当所有三个数据库调用完成后，我将按照我等待的顺序获得结果。 firstuserdata将从firstuserpromise获取响应，seconduserdata将从seconduserpromise获取响应，依此类推。

下面是一个假设代码，我希望它与上面的 javascript 代码等效：

package main

import "fmt"

func main() {
  set = make(chan, string)
  get = make(chan, string)

  // First DB call
  go firstDbCall()
  // Second DB call
  go secondDbCall()
  // Third DB call
  go thirdDbCall()

  // How to make sending data to channels predictable
  // First data to `set` channel will send data to firstDbCall
  // Second one will `set` to secondDbCall and so on.
  set <- "userId 1"
  set <- "userId 2"
  set <- "userId 3"

  // Similarly, How to make receiving data from channels predictable
  // firstUserData will data of "userId 1", secondUserData will have
  // data of "userId 2" and so on.
  firstUserData := <-get
  secondUserData := <-get
  thirdUserData := <-get
}

由于从通道获取数据是不可预测的，我如何才能使它们像 javascript 代码一样可预测？

解决方案

go 通道实际上只是线程安全队列。在这种情况下，队列（因此​​也是通道）看起来不适合您的用例。我建议查看 sync.waitgroup。

package main

import "sync"

func main() {
    var (
        firstUserData, secondUserData, thirdUserData string
        wg                                           sync.WaitGroup
    )
    wg.Add(3)

    // First DB call
    go func() {
        defer wg.Done()
        firstUserData = firstDbCall()
    }()

    // Second DB call
    go func() {
        defer wg.Done()
        secondUserData = secondDbCall()
    }()

    // Third DB call
    go func() {
        defer wg.Done()
        thirdUserData = thirdDbCall()
    }()

    wg.Wait()

    println(firstUserData, secondUserData, thirdUserData)
}

func firstDbCall() string {
    return "UserId1"
}

func secondDbCall() string {
    return "UserId2"
}

func thirdDbCall() string {
    return "UserId3"
}

今天关于《golang中如何顺序处理并发请求？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！