jjzjj

走例程:Making concurrent API requests

coder 2023-07-01 原文

我试图了解 channel 和协程，并尝试编写一个协程来向服务器发出并发 API 请求

但是当我使用 goroutine 运行代码时，它似乎花费了与没有 goroutine 相同的时间。

func sendUser(user string, ch chan<- string)  {
    resp,err := http.get("URL"/user)
    //do the processing and get resp=string
    ch <- resp
}


func AsyncHTTP(users []string) ([]string, error) {
    ch := make(chan string)
    var responses []string
    var user string

    for _ , user = range users {
        go sendUser(user, ch)

        for {
            select {
            case r := <-ch:
                if r.err != nil {
                    fmt.Println(r.err)
                }
                responses = append(responses, r)
                **//Is there a better way to show that the processing of response is complete**?
                if len(responses) == len(users) { 
                    return responses, nil
                }
            case <-time.After(50 * time.Millisecond):
                fmt.Printf(".")
            }
        }
    }
    return responses, nil
}

问题:

  1. 即使我使用了 goroutine，请求完成时间与没有 goroutine 时一样吗？我对 goroutine 做错了什么吗？

  2. 为了告诉作业不要再在这里等待，我正在使用:

    if len(responses) == len(users)

    有没有更好的方法来表明response的处理完成，告诉ch不要再等待了？

  3. 什么是 wait.Syncgroup？我如何在我的 goroutine 中使用它？

最佳答案

我可能会做这样的事情..

func sendUser(user string, ch chan<- string, wg *sync.WaitGroup) {
    defer wg.Done()
    resp, err := http.Get("URL/" + user)
    if err != nil {
        log.Println("err handle it")
    }
    defer resp.Body.Close()
    b, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        log.Println("err handle it")
    }
    ch <- string(b)
}

func AsyncHTTP(users []string) ([]string, error) {
    ch := make(chan string)
    var responses []string
    var user string
    var wg sync.WaitGroup
    for _, user = range users {
        wg.Add(1)
        go sendUser(user, ch, &wg)
    }

    // close the channel in the background
    go func() {
        wg.Wait()
        close(ch)
    }()
    // read from channel as they come in until its closed
    for res := range ch {
        responses = append(responses, res)
    }

    return responses, nil
}

它允许在发送时从 channel 中读取。通过使用 WaitGroup ，我将知道何时关闭 channel 。通过将 waitgroup 和 close 放在一个 goroutine 中，我可以“实时”地从 channel 中读取而不会阻塞。

关于走例程:Making concurrent API requests，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/45337881/

concurrentrequestsstringresponsessectiongoconcurrencychannelgoroutine

有关走例程:Making concurrent API requests的更多相关文章

  1. 一文带你通俗理解23种软件设计模式（推荐收藏，适合小白学习，附带C++例程完整源码） - 2

    作者：翟天保Steven版权声明：著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处一、设计模式是什么？    设计模式是为了解决在软件开发过程中遇到的某些问题而形成的思想。同一场景有多种设计模式可以应用，不同的模式有各自的优缺点，开发者可以基于自身需求选择合适的设计模式，去解决相应的工程难题。    良好的软件设计和架构，可以让代码具备良好的可读性、可维护性、可扩展性、可复用性，让整个系统具备较强的鲁棒性和性能，减少屎山代码出现的概率。    想要熟练运用设计模式，提高自己的编程能力和架构能力，只有在自己工作中，结合自身工作内容，多思考多实践。本文只能通过举一些通俗的例子，来

  2. javascript - 从 Javascript 访问 Chrome 的内部 gzip 例程 - 2

    所有现代浏览器都包含gzip例程，用于与服务器交换压缩数据。任何人都可以指出正确的方向来编写允许Javascript利用此例程的Chrome扩展吗？我想在通过WebSocket将数据发送到服务器之前用Javascript压缩一些数据，而Chrome内置的deflate例程肯定比我用Javascript编写的任何东西都快。 最佳答案 如果javascript实现对您来说不够快，您可以使用nativeclient.您将在c/c++中使用一些gzip库，并编写胶水代码，以便javascript可以通过native客户端调用它。如果可能的话

  3. go - go例程终止的可能场景 - 2

    关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗？更新问题，使其只关注一个问题editingthispost.关闭4年前。Improvethisquestiongoroutine必须永远运行的可能场景是什么？

  4. go - 如何计算死掉的例程？ - 2

    我有一段代码，我们运行多个go例程来接收值。我试图统计有多少goroutines由于某些异常或错误而死亡。我不想更新正常执行的计数。for{gofunc(){err:=receiveValues()}()}这里，receiveValues会调用其他函数，如果失败则返回errfuncrecieveValues()error{iferr,val:=callSomeFunc();err!=nil{returnerr}iferr2,val2:=callOtherFunc(val);err2!=nil{returnerr2}}我可以检查receiveValues()何时返回错误并增加我的计数，但

  5. Go:无法在go例程中创建服务器 - 2

    当尝试在go例程中ListenAndServer时出现错误:packagemainimport("fmt""io/ioutil""net/http")funcmain(){http.HandleFunc("/static/",myHandler)gofunc(){http.ListenAndServe("localhost:80",nil)}()fmt.Printf("wearehere")resp,_:=http.Get("localhost:80/static")ans,_:=ioutil.ReadAll(resp.Body)fmt.Printf("response:%s",ans

  6. unit-testing - 我如何测试代码是否真的启动了一个 go 例程？ - 2

    如果我在我的代码中创建一个go例程，我该如何编写一个测试用例来测试是否正在创建一个goroutine。 最佳答案 howdoIwriteatestcasethattestswhetheragoroutineisbeingcreated这绝不是您要寻找的。相反，您应该对测试进行检测，以检查go例程应该执行的操作是否确实发生了。 关于unit-testing-我如何测试代码是否真的启动了一个go例程？，我们在StackOverflow上找到一个类似的问题： htt

  7. go - 如何约束Go的grpc go例程个数 - 2

    有什么办法可以限制grpc客户端中的goroutines数量吗？我有一个使用grpc客户端的go应用程序，我发现有相当多的go例程正在创建并不断增长。感谢您的帮助。 最佳答案 如果你的问题是如何限制grpcgoroutines，没有办法，但我怀疑限制goroutine数量有什么意义。如果你达到了你的限制并且另一个请求来了怎么办？您可以在处理程序的开头使用类似信号量的模式，这样您就可以限制N个并发请求。额外的请求将等待其他请求完成后才开始处理(但是有N个goroutine，只有N个在工作)。Here是使用channel的信号量实现。

  8. 使用 Go 例程和变量时的 Go 插件核心转储 - 2

    我无法在go插件中启动的go例程中使用变量。以下代码是我正在尝试做的示例。代码//Canbeannon-emptystructaswellvarchannel=make(chanstring)log.Println(channel)gofunc(chchanstring){log.Println(ch)}(channel)在darwin上的go插件中执行时出现核心转储崩溃。-YesGo插件在darwin上工作:http://prntscr.com/iq8czy 最佳答案 我最近向golang报告了这个问题:Issuerelatedt

  9. 在 ec2 实例中执行例程 - 2

    我正在用golang编写应用程序，并且正在c5.18xlargeec2中进行一些测试来自aws的实例，它有72个vCPU。go例程将分布在72个vCPU中是否正确？ 最佳答案 如Go1.5发行说明所述Bydefault,GoprogramsrunwithGOMAXPROCSsettothenumberofcoresavailable;inpriorreleasesitdefaultedto1.所以从Go1.5开始，默认值应该是核数。这意味着是的，go例程应该分布在72个CPU中，除非您执行类似runtime.GOMAXPROCS(1

  10. go - 在 Intellij 中调试 Go 例程 - 2

    您好，我有一个包含GoRoutine的以下Golang程序。funcmain(){gofunc(){fmt.Println("BreakPoint1")}()fmt.Println("BreakPoint2")time.Sleep(100*time.Second)fmt.Println("hello")}现在我的程序不会在断点1处中断。我还如何调试例程？ 最佳答案 funcmain(){gofunc(){fmt.Println("BreakPoint1")}()fmt.Println("BreakPoint2")time.Sleep

随机推荐