如何使用Golang实现goroutine并发执行_使用goroutine管理多任务

Go语言通过goroutine实现轻量级并发，启动成本低（初始栈仅2KB），用go关键字启动，配合sync.WaitGroup协调多个goroutine的执行与等待，避免泄漏和竞态。

Go语言通过goroutine实现轻量级并发，无需手动管理线程生命周期，启动成本极低（初始栈仅2KB），适合高并发多任务场景。关键在于合理启动、协调与终止goroutine，避免泄漏和竞态。

启动goroutine执行独立任务

使用go关键字前缀函数调用即可启动goroutine。它会立即返回，不阻塞主流程：

• 普通函数：go doWork()
• 匿名函数：go func() { fmt.Println("task done") }()
• 带参数传递：go processItem(item)（注意传值而非引用，避免闭包变量复用问题）

等待多个goroutine完成：sync.WaitGroup

当需确保所有子任务执行完毕再继续，用sync.WaitGroup计数协调：

• 调用wg.Add(n)预设任务数
• 每个goroutine结束前调用wg.Done()
• 主goroutine调用wg.Wait()阻塞等待全部完成

示例：启动5个任务并统一等待

var wg sync.WaitGroup
for i := 0; i < 5; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        fmt.Printf("Task %d finished\n", id)
    }(i)
}
wg.Wait() // 主协程在此暂停，直到5个都调用Done

安全退出与资源清理：使用context.Context

长期运行的goroutine需支持主动取消。用context.WithCancel生成可取消上下文：

• 主goroutine调用cancel()通知所有监听该context的goroutine退出
• 子goroutine通过select监听ctx.Done()通道判断是否中止
• 可在case 分支中执行清理操作（如关闭文件、释放连接）

避免常见陷阱

goroutine易出错点需特别注意：

• 循环变量捕获错误：for循环中直接go f(i)可能所有goroutine看到同一个i值 → 改为go f(i)传参或go func(val int){...}(i)
• 主goroutine提前退出：若不等待或不处理Done信号，程序可能在子任务完成前就结束 → 必须用WaitGroup或context控制生命周期
• 无缓冲channel阻塞：向无缓冲channel发送数据时，若无接收方将永久阻塞goroutine → 确保配对收发，或使用带缓冲channel/select超时