登录
首页 >  Golang >  Go问答

利用通道实现并行 for 循环

来源:stackoverflow

时间:2024-03-25 19:06:35 260浏览 收藏

本文探讨了使用通道在 Go 中实现并行 for 循环的两种方法。第一种方法涉及使用非通道变量 `sum`,这可能会导致阻塞操作。第二种方法通过使用通道 `sum` 来传递值,但由于无法直接将值从一个通道传递到另一个通道,因此需要使用临时变量 `temp`。作者建议使用诸如 `sync.mutex` 或 `atomic.adduint64` 之类的经典方法来求和数字,但修改了第二种方法以使其正常工作。

问题内容

func parallelsum (c chan int){
  sum := 0
  for i :=1 ; i< 100;i++{
    go func(i int){
        sum += i
    }(i)
  }
    time.sleep(1*time.second)
    c <- sum
}

我正在尝试学习并行能力来加速 openmp 等事物。这是 go 中预期求和并行循环的示例,该函数作为 goroutine 运行。

请注意,这里变量 sum 不是通道,那么这是否意味着 for 循环内的变量 sum 访问是阻塞操作?现在效率够了吗?有更好的解决办法吗?

我知道通道功能是为此设计的,下面我明显错误的实现可以编译,但有 100 个运行时错误,如下所示。

goroutine 4 [chan receive]:
main.parallelsumerror(0xc0000180c0)
    /home/tom/src/goland_newproject/main.go:58 +0xb4 //line 58 : temp := <-sum
created by main.main
    /home/tom/src/goland_newproject/main.go:128 +0x2ca //line 128: go parallelsumerror(pcr), the calling function

那么这里有什么问题呢?看起来求和并不是并行 for 循环的一个很好的例子,但实际上我想知道如何在并行 for 循环中使用通道。

func parallelsum (c chan int){
    sum := make(chan int)
    for i :=1 ; i< 100;i++{
        go func(i int){
            temp := <- sum //error here why?
            temp += i
            sum <- temp
        }(i)
    }
    time.sleep(1*time.second)
    temp := <-sum
    c <- temp
}

两者具有相同的主要功能

func main(){
    pc := make(chan int)
    go parallelSum(pc) 
    result = <- pc
    fmt.Println("parallel result:", result)
}

解决方案


我不喜欢通过渠道对数字求和的想法。我宁愿使用像 sync.mutexatomic.adduint64 这样的经典东西。但是,至少,我让你的代码正常工作了。 我们无法将值从一个通道传递到另一个通道(我添加了 temp 变量)。另外,还有 sync.waitgroup 和其他东西。 但我仍然不喜欢代码的想法。

package main

import (
"fmt"
"sync"
)

func main() {
    pc := make(chan int)
    go parallelSum(pc)
    result := <- pc
    fmt.Println("parallel result:", result)
}


func parallelSum (c chan int){
    sum := make(chan int)


    wg := sync.WaitGroup{}
    wg.Add(100)

    for i :=1 ; i <= 100;i++{
        go func(i int){
            temp := <- sum
            temp += i
            wg.Done()

            sum <- temp
        }(i)
    }

    sum <- 0

    wg.Wait()
    temp := <- sum
    c <- temp
}

终于介绍完啦!小伙伴们,这篇关于《利用通道实现并行 for 循环》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

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