Go 语言并发

在学习 Go 语言之前我对并发的理解一直停留在一个比较浅的层面并发 同时运行多个任务。比如开一个线程下载文件开多个线程处理请求多个任务一起执行提高效率。但真正学习 Go 的并发模型后我发现 Go 对并发的理解并不是简单地“让多个任务同时跑”。Go 更关注的是如何让多个执行单元安全、高效地协作。这也是 Go 语言设计哲学中非常重要的一部分不要通过共享内存来通信而应该通过通信来共享内存。这句话也成为了 Go 并发设计的核心。一、为什么需要并发我们先思考一个问题假设一个程序需要完成三个任务任务A读取文件 任务B处理数据 任务C发送网络请求如果按照传统的顺序执行A → B → C那么A 等待磁盘读取时CPU 可能空闲C 等待网络响应时程序也无法做其他事情。大量时间浪费在等待上。如果能够A \ B \ C三个任务同时推进那么程序整体效率就会提升。这就是并发存在的意义充分利用计算资源让程序在等待的时候继续做其他事情。二、进程、线程、协程Go 处在哪一层在理解 Go 并发之前需要先区分几个概念。1. 进程Process进程是操作系统进行资源分配的基本单位。例如打开浏览器Chrome进程打开微信微信进程每个进程都有独立内存空间文件资源系统资源。进程之间相互隔离。优点稳定一个进程崩溃不会影响其他进程。缺点创建成本高通信复杂。2. 线程Thread线程是进程内部的执行单位。例如一个浏览器进程Chrome进程 ├── UI线程 ├── 网络线程 └── 渲染线程多个线程共享进程资源。优点创建成本低通信方便。缺点共享数据容易产生问题。例如两个线程同时修改一个变量count可能出现线程A读取 count 0 线程B读取 count 0 线程A 1 线程B 1 最终: count 1明明执行两次结果却是 1。这就是经典的线程安全问题。3. 协程GoroutineGo 没有直接让开发者操作线程。而是提供Goroutine它是一种轻量级执行单位。例如普通线程线程1 线程2 线程3可能需要 MB 级别内存。而 Goroutinegoroutine1 goroutine2 goroutine3 ... goroutine10000可以轻松创建大量数量。创建一个 Goroutinego task()非常简单。例如package main import ( fmt time ) func hello() { fmt.Println(hello goroutine) } func main() { go hello() time.Sleep(time.Second) }这里go hello()表示启动一个新的 Goroutine 执行 hello。三、Goroutine 和线程有什么区别很多初学者会认为Goroutine Go里面的线程其实不是。它们关系操作系统 ↓ 线程 Thread ↓ Go Runtime ↓ Goroutine一个程序Go程序 ├── 线程1 │ ├── goroutine A │ ├── goroutine B │ ├── 线程2 ├── goroutine C └── goroutine DGo Runtime 会负责创建 Goroutine调度 Goroutine分配线程。开发者不需要关心线程管理。这也是 Go 简化并发开发的重要原因。四、Go 的并发调度模型 GMPGo 的并发调度依靠 GMP 模型。三个核心GGoroutine表示用户创建的任务。例如go func(){ fmt.Println(hello) }()这个函数就是一个 G。MMachine表示操作系统线程。真正执行代码的是线程。PProcessor表示调度器资源。负责管理 Goroutine分配给线程执行。整体关系P G G G G G ↓ M 操作系统线程简单理解G 是任务M 是执行者P 是调度管理员。五、并发中的核心问题数据共享并发最大的难点不是启动多个任务。而是多个任务同时修改数据怎么办例如count : 0 go func(){ count }() go func(){ count }()两个 Goroutine 同时修改可能产生结果 1 而不是 2怎么办Go 提供两种思想六、方式一共享内存 锁传统方式多个线程共享变量。Go 提供sync.Mutex例如var mutex sync.Mutex mutex.Lock() count mutex.Unlock()含义修改数据之前加锁其他 Goroutine等待修改完成释放锁这样保证安全。七、方式二ChannelGo推荐方式Go 更推荐不共享数据而通过通信传递数据。例如创建 channelch : make(chan int)发送数据ch - 10接收数据num : -ch例如func worker(ch chan int){ ch - 100 } func main(){ ch : make(chan int) go worker(ch) result : -ch fmt.Println(result) }流程worker goroutine | | ↓ channel | | ↓ main goroutine数据通过 channel 流动。八、为什么 Go 推崇 Channel因为共享内存多个地方修改同一个变量容易出现加锁死锁数据竞争。而 Channel生产者 ↓ Channel ↓ 消费者更加符合现实世界。类似工厂生产生产线 → 仓库 → 消费者每个人负责自己的事情。九、并发不是越多越好学习并发后一个容易犯的错误创建越多 Goroutine程序越快。实际上不是。例如创建100万个goroutine可能导致调度压力增加内存增加上下文切换增加。并发设计需要考虑CPU数量任务类型数据竞争。合理的并发不是数量多。而是让任务之间合理协作。十、Go 并发带来的思考学习 Go 并发之后我最大的感受是以前学习多线程关注的是如何让多个线程同时运行而 Go关注的是多个任务之间如何合作完成目标。这是一种编程思想上的变化。并发并不是简单地把任务拆开。真正困难的是谁负责什么数据如何流动如何避免互相干扰Go 通过 Goroutine 降低了创建并发任务的成本通过 Channel 提供了一种更安全的数据交换方式。最终实现用简单的代码表达复杂的并发逻辑。这也是 Go 语言能够在服务器开发、云计算、微服务领域广泛应用的重要原因。总结本文学习了 Go 并发中的几个核心概念进程、线程、协程的区别Goroutine 的特点GMP 调度模型并发中的数据竞争问题Mutex 和 Channel 的区别Go 的并发设计思想。如果说传统并发是在解决“如何让多个任务一起运行”那么 Go 给出的答案是“如何让多个任务更优雅地协作。”这也是 Go 语言并发设计最吸引人的地方。