当前位置:

首页 > 编程开发 > Go并发处理切片:WaitGroup实现安全并行调用

Go并发处理切片:WaitGroup实现安全并行调用

本文详解如何将顺序遍历切片并调用函数的操作改为真正的并发执行,避免常见闭包捕获错误和切片越界问题,使用sync.WaitGroup安全收集结果。

本文目录

    Go 并发处理切片:使用 WaitGroup 实现安全的并行函数调用

    本文详解如何将顺序遍历切片并调用函数的操作改为真正的并发执行,避免常见闭包捕获错误和切片越界问题,使用 sync.WaitGroup 安全收集结果。

    在 Go 中实现切片元素的并行处理,核心目标是:对每个输入值独立启动 goroutine 执行计算(如 double(i)),不相互阻塞,最终按原始顺序聚合结果。初学者常误用 channel 切片(如 []chan int)并陷入索引越界或闭包变量捕获陷阱——这正是原代码中 chans[i] = make(chan int) panic 的根源:chans 被声明为零长度切片,却直接通过索引赋值。

    更简洁、安全且符合 Go 习惯的做法是:预分配结果切片 + sync.WaitGroup 协调完成信号 + 显式传参避免闭包陷阱。以下是优化后的完整实现:

    package main
    
    import (
        "fmt"
        "sync"
        "time"
    )
    
    func double(i int) int {
        result := 2 * i
        fmt.Printf("double(%d) = %d\n", i, result)
        time.Sleep(500 * time.Millisecond) // 模拟耗时操作(原代码为 500ms,非 500ns)
        return result
    }
    
    func notParallel(arr []int) []int {
        outArr := make([]int, 0, len(arr))
        for _, i := range arr {
            outArr = append(outArr, double(i))
        }
        return outArr
    }
    
    func parallel(arr []int) []int {
        n := len(arr)
        outArr := make([]int, n) // 预分配,确保索引安全
        var wg sync.WaitGroup
    
        for i, num := range arr {
            wg.Add(1)
            // 关键:显式将 i 和 num 作为参数传入 goroutine
            // 避免循环变量被所有 goroutine 共享(闭包陷阱)
            go func(idx int, value int) {
                defer wg.Done()
                outArr[idx] = double(value)
            }(i, num)
        }
    
        wg.Wait() // 主协程等待所有 goroutine 完成
        return outArr
    }
    
    func main() {
        arr := []int{7, 8, 9}
        fmt.Println("=== 顺序执行 ===")
        start := time.Now()
        seq := notParallel(arr)
        fmt.Printf("结果: %v, 耗时: %v\n", seq, time.Since(start))
    
        fmt.Println("\n=== 并发执行 ===")
        start = time.Now()
        conc := parallel(arr)
        fmt.Printf("结果: %v, 耗时: %v\n", conc, time.Since(start))
    }

    关键要点说明:

    • ✅ 预分配结果切片:outArr := make([]int, len(arr)) 确保后续 outArr[i] = ... 不会 panic;
    • ✅ WaitGroup 精确计数:wg.Add(1) 在 goroutine 启动前调用,defer wg.Done() 保证异常时也能释放;
    • ✅ 闭包安全传参:go func(idx, value int) { ... }(i, num) 将当前循环变量值拷贝传入,杜绝 i 和 num 在循环结束后被覆盖导致的竞态;
    • ⚠️ 无需 channel 切片:本场景只需“写入固定位置”,channel 带来额外复杂度(缓冲管理、接收阻塞、关闭逻辑),反而降低可读性与性能;
    • ? 时间验证:3 个元素各耗时 ~500ms,顺序执行约 1500ms,而并发执行接近 500ms(取决于调度开销),效果显著。

    若未来需处理不确定数量结果、或需流式消费中间结果,则 channel 方案才具优势——但此时应使用单个 chan T 配合 for range 接收,而非 channel 切片。对于确定长度、顺序敏感的并行映射(map-reduce 中的 map 阶段),WaitGroup + 预分配切片 是最推荐的 Go 模式。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发
    相关文章 更多
    OpenCode PTY 0.5.2:发布 protocol 8 终端服务组件
    OpenCode PTY 0.5.2:发布 protocol 8 终端服务组件

    OpenCode发布opencode-pty 0.5.2终端服务组件,使用protocol 8并以@opencode/pty@0.5.2发布到npm。它面向集成终端子进程的开发者,采用MIT许可,仍被项目说明为实验性服务核心,不是OpenCode整款应用的版本号。

    vLLM 0.34.0rc2 源码标签:调整可扩展 KV Cache 测试内存参数
    vLLM 0.34.0rc2 源码标签:调整可扩展 KV Cache 测试内存参数

    vLLM出现0.34.0rc2候选源码标签,关联提交移除多处可扩展KV Cache测试和基准中的固定gpu_memory_utilization设置,并调整相关文档。当前核验的是标签与代码提交,不能将其当作正式版安装包或全局显存默认值变更。

    llama.cpp b12318:新增 CUDA 调试缓冲池与 Sanitizer 说明
    llama.cpp b12318:新增 CUDA 调试缓冲池与 Sanitizer 说明

    llama.cpp b12318新增CUDA调试缓冲池,并补充与compute-sanitizer相关的代码说明。它是面向CUDA开发调试路径的预发布构建,不能据此推断普通推理速度、显存占用或所有后端发生同等变化。

    llama.cpp b12307:修复 Metal SOLVE_TRI 内核越界读取
    llama.cpp b12307:修复 Metal SOLVE_TRI 内核越界读取

    llama.cpp b12307修复Metal后端SOLVE_TRI内核的越界读取,属于预发布构建中的特定计算路径补丁。使用Metal后端的开发者应核对是否涉及该算子,并验证模型加载与推理;公告未给出CVE、确认利用或统一性能结论。

    n8n 2.48.2 Beta:修复新草稿中的 Agent 标签页可用性
    n8n 2.48.2 Beta:修复新草稿中的 Agent 标签页可用性

    n8n 2.48.2是预发布版本,修复编辑器中新草稿的Agent标签页可用性,并包含只读凭据节点API约束及边框修复。本条新增关注Beta编辑器路径,稳定版用户无需仅因版本号较高就切换渠道。

    Tug 0.9.2:新增上手帮助,改进会话创建与主题显示
    Tug 0.9.2:新增上手帮助,改进会话创建与主题显示

    Tug 0.9.2新增Getting Started帮助卡,可在会话选择器中创建不存在的目录,并改进拖放输入、会话状态与主题颜色。它是MIT开源的macOS AI编程IDE,仍属beta,需要Apple silicon Mac及macOS 15或更新版本,并依赖包含Claude Code的付费计划。

    Ducter 0.0.38 源码标签:修复 Slack 主动提醒与启动后邮件回看
    Ducter 0.0.38 源码标签:修复 Slack 主动提醒与启动后邮件回看

    Ducter 0.0.38源码标签修复Slack提及和私信进入watcher、启动后账号未就绪导致邮件回看空跑等问题。本轮确认的是源码标签及更新日志,核验时官网安装入口仍指向0.0.37,不能当作0.0.38安装包已上线。

    LangChain TypeSafe 0.1.0:分类器接口迁移,Python 与 JS 依赖要求调整
    LangChain TypeSafe 0.1.0:分类器接口迁移,Python 与 JS 依赖要求调整

    LangChain TypeSafe 0.1.0将TypeSafeClassifier对齐决策模型接口。JavaScript的问题改为随请求传入,响应和usage字段调整,旧中间件入口弃用;Python版最低Python 3.11、langchain-core 1.8.0,跨语言依赖要求需要分别核对。

    GitHub Copilot CLI 1.0.110-3:改进 Entra 登录,修复 MCP 配置保存
    GitHub Copilot CLI 1.0.110-3:改进 Entra 登录,修复 MCP 配置保存

    GitHub Copilot CLI 1.0.110-3是预发布补丁,改善Microsoft Entra登录与终端显示,并在MCP配置文件无效时保留原配置、显示保存错误。技能描述中的不可见转义内容不再参与命令匹配,升级需验证相应终端和集成路径。

    LiteLLM 修复分支扩展:1.106.9、1.108.6 与 1.110.0-rc.2 更新
    LiteLLM 修复分支扩展:1.106.9、1.108.6 与 1.110.0-rc.2 更新

    LiteLLM将请求字段与部署配置冲突的修复覆盖到1.106.9、1.108.6及1.110.0-rc.2。维护旧稳定分支或候选分支的团队应选择对应修复版本;1.108.6还包含预算重置、用量细分和其他回移,不能将RC视为稳定版。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。