当前位置:首页 > 文章列表 > Golang > Go问答 > 利用通道实现并行 for 循环

利用通道实现并行 for 循环

来源:stackoverflow 2024-03-25 19:06:35 0浏览 收藏

本文探讨了使用通道在 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删除
CVPR 2024 | SAM-6D框架:实现零样本6D物体姿态估计,推动智能技术前进CVPR 2024 | SAM-6D框架:实现零样本6D物体姿态估计,推动智能技术前进
上一篇
CVPR 2024 | SAM-6D框架:实现零样本6D物体姿态估计,推动智能技术前进
指针接收器函数中使用 nil 是安全的吗?
下一篇
指针接收器函数中使用 nil 是安全的吗?
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    515次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    499次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    484次学习
查看更多
AI推荐
  • PandaWiki开源知识库:AI大模型驱动,智能文档与AI创作、问答、搜索一体化平台
    PandaWiki开源知识库
    PandaWiki是一款AI大模型驱动的开源知识库搭建系统,助您快速构建产品/技术文档、FAQ、博客。提供AI创作、问答、搜索能力,支持富文本编辑、多格式导出,并可轻松集成与多来源内容导入。
    3次使用
  • SEO  AI Mermaid 流程图:自然语言生成,文本驱动可视化创作
    AI Mermaid流程图
    SEO AI Mermaid 流程图工具:基于 Mermaid 语法,AI 辅助,自然语言生成流程图,提升可视化创作效率,适用于开发者、产品经理、教育工作者。
    822次使用
  • 搜获客笔记生成器:小红书医美爆款内容AI创作神器
    搜获客【笔记生成器】
    搜获客笔记生成器,国内首个聚焦小红书医美垂类的AI文案工具。1500万爆款文案库,行业专属算法,助您高效创作合规、引流的医美笔记,提升运营效率,引爆小红书流量!
    839次使用
  • iTerms:一站式法律AI工作台,智能合同审查起草与法律问答专家
    iTerms
    iTerms是一款专业的一站式法律AI工作台,提供AI合同审查、AI合同起草及AI法律问答服务。通过智能问答、深度思考与联网检索,助您高效检索法律法规与司法判例,告别传统模板,实现合同一键起草与在线编辑,大幅提升法律事务处理效率。
    857次使用
  • TokenPony:AI大模型API聚合平台,一站式接入,高效稳定高性价比
    TokenPony
    TokenPony是讯盟科技旗下的AI大模型聚合API平台。通过统一接口接入DeepSeek、Kimi、Qwen等主流模型,支持1024K超长上下文,实现零配置、免部署、极速响应与高性价比的AI应用开发,助力专业用户轻松构建智能服务。
    922次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码