登录
首页 >  Golang >  Go教程

Golang协程教程:轻松创建并发任务

时间:2026-03-03 19:50:40 169浏览 收藏

本文深入浅出地讲解了 Go 语言中 goroutine 这一核心并发机制的实战用法:从用 go 关键字快速启动轻量级协程,到必须掌握的 sync.WaitGroup 同步技巧以避免主协程过早退出导致任务丢失;同时直击初学者常见陷阱——循环变量闭包问题,并给出传参、局部变量赋值等安全解决方案;最后强调 Go 的并发哲学——“不要通过共享内存来通信,而要通过通信来共享内存”,引导读者使用 channel 实现高效、安全的异步协作与结果聚合,真正迈出高并发编程的坚实一步。

如何在Golang中使用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 是最常用的方式:

  • 调用 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 泄漏(若未接收,发送会阻塞),是构建可靠异步任务流的核心工具。

到这里,我们也就讲完了《Golang协程教程:轻松创建并发任务》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

资料下载
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>