信息发布→ 登录 注册 退出

如何在Golang中使用goroutine实现并发_创建协程并执行异步任务

发布时间:2026-01-06

点击量:
Go 中 goroutine 是轻量级并发单元,用 go 关键字启动;需用 sync.WaitGroup 等同步机制防止主 goroutine 提前退出导致其他协程被终止。

在 Go 中,goroutine 是轻量级的并发执行单元,由 Go 运行时管理,创建成本极低,适合高并发场景。使用 go 关键字即可启动一个 goroutine,它会异步执行函数调用,主线程无需等待。

启动 goroutine 的基本方式

只需在函数调用前加 go,该函数就会在新协程中运行:

  • go func() { fmt.Println("hello from goroutine") }() —— 启动匿名函数
  • go doWork(x, y) —— 启动已定义函数(注意:传参需传值或显式取地址)

注意:如果主 goroutine(main 函数)很快结束,其他 goroutine 可能被强制终止,因此常需同步机制控制生命周期。

等待 goroutine 完成:使用 sync.WaitGroup

当需要确保若干 goroutine 执行完毕后再继续,sync.WaitGroup 是最常用的方式:

立即学习“go语言免费学习笔记(深入)”;

  • 调用 wg.Add(n) 告知预期启动的 goroutine 数量
  • 每个 goroutine 结束前调用 wg.Done()
  • 主 goroutine 调用 wg.Wait() 阻塞等待全部完成

示例:

func main() {
  var wg sync.WaitGroup
  for i := 0; i     wg.Add(1)
    go func(id int) {
      defer wg.Done()
      fmt.Printf("Task %d done\n", id)
    }(i)
  }
  wg.Wait()
}

安全传递数据:避免变量共享陷阱

循环中直接使用循环变量(如 for i := range items)启动 goroutine 时,容易因闭包捕获同一变量地址而引发竞态。解决方法:

  • 将变量作为参数传入 goroutine(推荐):go f(i)
  • 在循环内定义新变量并赋值:val := i; go f(val)
  • 使用 range 时注意:切片索引和元素值都需显式传参

配合 channel 实现异步通信与结果收集

goroutine 之间不建议直接共享内存,应通过 channel 通信。例如并发请求并汇总结果:

  • 创建带缓冲或无缓冲 channel 接收结果
  • 每个 goroutine 执行完后向 channel 发送结果:ch
  • 主 goroutine 从 channel 接收所有结果(可配合 for range chfor i := 0; i )

channel 天然支持同步,还能防止 goroutine 泄漏(若未接收,发送会阻塞),是构建可靠异步任务流的核心工具。

标签:# 闭包  # 需用  # 学习笔记  # 极低  # 最常用  # 完后  # 它会  # 会在  # 只需  # 还能  # 异步  # channel  # 并发  # 切片  # go  # var  # 主线程  # 线程  # 循环  # int  # printf  # for  # 同步机制  # 并发请求  # 异步任务  # 解决方法  # ai  # golang  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!