登录
首页 >  Golang >  Go问答

为什么 Goroutines 花费的时间与顺序执行的时间几乎相同?

来源:stackoverflow

时间:2024-04-08 16:36:33 380浏览 收藏

有志者,事竟成!如果你在学习Golang,那么本文《为什么 Goroutines 花费的时间与顺序执行的时间几乎相同?》,就很适合你!文章讲解的知识点主要包括,若是你对本文感兴趣,或者是想搞懂其中某个知识点,就请你继续往下看吧~

问题内容

我正在调用两个函数,每个函数都有一个 go 例程,我预计同时执行它们所需的时间应该比一次运行一个函数要少得多。但我看到的情况恰恰相反,并行运行它们需要相同或有时更少的时间。

协程

    start := time.now()
    incomechan := make(chan func() ([]models.cashflow, *models.errorresponse))
    expensechan := make(chan func() ([]models.cashflow, *models.errorresponse))

    go func(from, to string, cr *fa.client, c chan<-func() ([]models.cashflow, *models.errorresponse)) {
        log.println("fetching income")
        c <- func() ([]models.cashflow, *models.errorresponse) { return incomes(from, to, cr)}
        close(c)
    }(from, to, cr, incomechan)

    go func(from, to string, cr *fa.client, c chan<-func() ([]models.cashflow, *models.errorresponse)){
        log.println("fetching expenses")
        c <- func() ([]models.cashflow, *models.errorresponse) {return expenses(from, to, cr)}
        close(c)
    } (from, to, cr, expensechan)

    income, inerr := (<- incomechan)()
    if inerr != nil {
        log.printf("%#v", inerr)
        w.writeheader(inerr.code)
        fmt.fprint(w, helper.jsonstringify(inerr))
        return
    }
    log.println("income fetch completed")

    expense, exerr := (<- expensechan)()
    if exerr != nil {
        log.printf("%#v", exerr)
        w.writeheader(exerr.code)
        fmt.fprint(w, helper.jsonstringify(exerr))
        return
    }
    log.println("expense fetch completed")
    fmt.printf("%.2fs elapsed\n", time.since(start).seconds())

输出

3.33s elapsed
2.79s elapsed
3.37s elapsed

顺序

    income, inerr := incomes(from, to, cr)
    if inerr != nil {
        log.printf("%#v", inerr)
        w.writeheader(inerr.code)
        fmt.fprint(w, helper.jsonstringify(inerr))
        return
    }
    
    expense, exerr := expenses(from, to, cr)
    if exerr != nil {
        log.printf("%#v", exerr)
        w.writeheader(exerr.code)
        fmt.fprint(w, helper.jsonstringify(exerr))
        return
    }

    fmt.printf("%.2fs elapsed\n", time.since(start).seconds())

输出

2.98s elapsed
3.03s elapsed
2.70s elapsed

是我做错了什么吗?我预计它花在 goroutine 上的时间会更少。

如果有人知道我在这里可能做错了什么或有任何建议,非常感谢。


解决方案


首先,您将并行性与并发性混淆了。 Goroutines 处理并发,而不是并行。有关差异的更多背​​景信息,Go 的创建者之一举办了一场名为 Concurrency is not Parallelism 的演讲。

现在给出一个实际的答案。

您的 goroutine 实际上并不处理任一函数的任何处理,而是发送一个调用 expenses Revenues 的函数,然后您依次调用它们。这意味着在您调用 venue, inErr := (<-venueChan)() 之前,不会计算 venues() 的实际结果。

本质上,您的“Goroutines”示例在功能上与您的“Sequential”示例相同,但具有 goroutine 带来的额外开销,因为它们不能保证立即调度。

以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持golang学习网!更多关于Golang的相关知识,也可关注golang学习网公众号。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>