Golang如何使用goroutine实现并发执行

你在学习Golang相关的知识吗？本文《Golang如何使用goroutine实现并发执行》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

Go中goroutine启动后不阻塞主函数，主函数退出则所有goroutine强制终止；需用sync.WaitGroup等待或time.Sleep临时观察，且循环中传参避免闭包陷阱；channel使用不当易致泄漏或死锁。

goroutine 启动后不等待，主函数退出就结束

Go 的 goroutine 是轻量级线程，但启动后默认不阻塞主流程。如果主函数执行完直接退出，所有未完成的 goroutine 会被强制终止，看不到输出。

• 用 time.Sleep() 临时观察效果（仅测试用，不可用于生产）
• 更可靠的方式是用 sync.WaitGroup 等待所有任务完成
• 避免在循环中直接启动 goroutine 并传入循环变量——容易捕获到变量最终值，需显式传参或用局部变量捕获

package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 3; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        fmt.Printf("goroutine %d running\n", id)
        time.Sleep(time.Second)
    }(i) // 注意：这里把 i 作为参数传入，避免闭包陷阱
}

wg.Wait() // 主 goroutine 阻塞等待全部完成
fmt.Println("all done")
}

goroutine 泄漏：忘记关闭 channel 或未消费完数据

当用 channel 配合 goroutine 做生产者-消费者模型时，若发送端关闭了 channel，但接收端没处理完或没检测关闭状态，可能造成接收 goroutine 永久阻塞；反之，若接收端已退出而发送端还在往无缓冲 channel 写，也会死锁。

• 使用 for range ch 自动处理 channel 关闭
• 带缓冲的 channel 能缓解压力，但不能替代逻辑控制
• 超时控制推荐用 select + time.After()，避免无限等待

go func(ch chan int) {
    for i := 0; i 
大量 goroutine 启动导致内存或调度压力
每个 goroutine 初始栈约 2KB，虽轻量，但百万级并发仍会耗尽内存；同时 Go 调度器不是为“越多越好”设计的，过度创建反而降低吞吐。

• 用 runtime.GOMAXPROCS(n) 控制并行数（通常保持默认即可）
• 对 I/O 密集型任务，优先用 channel + worker pool 模式限制并发数，而非为每个请求启一个 goroutine
• 可通过 runtime.NumGoroutine() 监控当前数量，排查泄漏

goroutine 中 panic 不会传播到主 goroutine

每个 goroutine 独立运行，其中的 panic 默认只终止自身，不会中断主流程，也容易被忽略。

• 用 recover() 在 goroutine 内部捕获 panic（必须在 defer 中调用）
• 不要依赖外部监控捕获 goroutine panic——它根本不会冒泡出去
• 日志中需明确标注 panic 来自哪个 goroutine，例如打上 ID 或上下文

go func(id int) {
    defer func() {
        if r := recover(); r != nil {
            fmt.Printf("goroutine %d panicked: %v\n", id, r)
        }
    }()
    panic("something went wrong")
}(1)

实际写并发逻辑时，最常被忽略的是「等待机制」和「错误隔离」——前者导致程序提前退出、结果丢失，后者导致 panic 静默失败、问题难以复现。

今天关于《Golang如何使用goroutine实现并发执行》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！