Go语言CSP：通信顺序进程简述
首页
教程
VIP会员
一对一答疑
辅导班
公众号
首页
C语言教程
C++教程
Python教程
Java教程
Linux入门
更多>>
目录
Go语言
Go语言简介
Go语言基本语法
Go语言容器
流程控制
Go语言函数
Go语言结构体
Go语言接口
Go语言包（package）
9 Go语言并发 9.1 Go语言并发简述9.2 Go语言轻量级线程9.3 Go语言并发通信9.4 Go语言竞争状态9.5 Go语言调整并发的运行性能9.6 并发和并行的区别9.7 goroutine和coroutine的区别9.8 Go语言通道（chan）9.9 示例：并发打印9.10 Go语言单向通道9.11 Go语言无缓冲的通道9.12 Go语言带缓冲的通道9.13 Go语言channel超时机制9.14 Go语言通道的多路复用9.15 Go语言模拟远程过程调用9.16 示例：使用通道响应计时器的事件9.17 Go语言关闭通道后继续使用通道9.18 Go语言多核并行化9.19 Go语言Telnet回音服务器9.20 检测代码在并发环境下可能出现的问题9.21 互斥锁和读写互斥锁9.22 Go语言等待组9.23 死锁、活锁和饥饿概述9.24 示例：封装qsort快速排序函数9.25 Go语言CSP：通信顺序进程简述9.26 示例：聊天服务器9.27 高效地使用Go语言并发特性9.28 使用select切换协程9.29 Go语言加密通信
10
Go语言反射
11
Go语言文件处理
12
Go语言编译与工具
首页 > Go语言 > Go语言并发
Go语言CSP：通信顺序进程简述
Go实现了两种并发形式，第一种是大家普遍认知的多线程共享内存，其实就是 Java 或 C++ 等语言中的多线程开发；另外一种是Go语言特有的，也是Go语言推荐的 CSP（communicating sequential processes）并发模型。
CSP 并发模型是上个世纪七十年代提出的，用于描述两个独立的并发实体通过共享 channel（管道）进行通信的并发模型。
Go语言就是借用 CSP 并发模型的一些概念为之实现并发的，但是Go语言并没有完全实现了 CSP 并发模型的所有理论，仅仅是实现了 process 和 channel 这两个概念。
process 就是Go语言中的 goroutine，每个 goroutine 之间是通过 channel 通讯来实现数据共享。
这里我们要明确的是“并发不是并行”。并发更关注的是程序的设计层面，并发的程序完全是可以顺序执行的，只有在真正的多核 CPU 上才可能真正地同时运行；并行更关注的是程序的运行层面，并行一般是简单的大量重复，例如 GPU 中对图像处理都会有大量的并行运算。
为了更好地编写并发程序，从设计之初Go语言就注重如何在编程语言层级上设计一个简洁安全高效的抽象模型，让开发人员专注于分解问题和组合方案，而且不用被线程管理和信号互斥这些烦琐的操作分散精力。
在并发编程中，对共享资源的正确访问需要精确地控制，在目前的绝大多数语言中，都是通过加锁等线程同步方案来解决这一困难问题，而Go语言却另辟蹊径，它将共享的值通过通道传递（实际上多个独立执行的线程很少主动共享资源）。
并发编程的核心概念是同步通信，但是同步的方式却有多种。先以大家熟悉的互斥量 sync.Mutex 来实现同步通信，示例代码如下所示：
package main
import (
"fmt"
"sync"
func main() {
var mu sync.Mutex
go func() {
fmt.Println("C语言中文网")
mu.Lock()
}()
mu.Unlock()
由于 mu.Lock() 和 mu.Unlock() 并不在同一个 Goroutine 中，所以也就不满足顺序一致性内存模型。同时它们也没有其他的同步事件可以参考，也就是说这两件事是可以并发的。
因为可能是并发的事件，所以 main() 函数中的 mu.Unlock() 很有可能先发生，而这个时刻 mu 互斥对象还处于未加锁的状态，因而会导致运行时异常。
下面是修复后的代码：
package main
import (
"fmt"
"sync"
func main() {
var mu sync.Mutex
mu.Lock()
go func() {
fmt.Println("C语言中文网")
mu.Unlock()
}()
mu.Lock()
修复的方式是在 main() 函数所在线程中执行两次 mu.Lock()，当第二次加锁时会因为锁已经被占用（不是递归锁）而阻塞，main() 函数的阻塞状态驱动后台线程继续向前执行。
当后台线程执行到 mu.Unlock() 时解锁，此时打印工作已经完成了，解锁会导致 main() 函数中的第二个 mu.Lock() 阻塞状态取消，此时后台线程和主线程再没有其他的同步事件参考，它们退出的事件将是并发的，在 main() 函数退出导致程序退出时，后台线程可能已经退出了，也可能没有退出。虽然无法确定两个线程退出的时间，但是打印工作是可以正确完成的。
使用 sync.Mutex 互斥锁同步是比较低级的做法，我们现在改用无缓存通道来实现同步：
package main
import (
"fmt"
func main() {
done := make(chan int)
go func() {
fmt.Println("C语言中文网")
<-done
}()
done <- 1
根据Go语言内存模型规范，对于从无缓存通道进行的接收，发生在对该通道进行的发送完成之前。因此，后台线程<-done 接收操作完成之后，main 线程的done <- 1 发送操作才可能完成（从而退出 main、退出程序），而此时打印工作已经完成了。
上面的代码虽然可以正确同步，但是对通道的缓存大小太敏感，如果通道有缓存，就无法保证 main() 函数退出之前后台线程能正常打印了，更好的做法是将通道的发送和接收方向调换一下，这样可以避免同步事件受通道缓存大小的影响：
package main
import (
"fmt"
func main() {
done := make(chan int, 1) // 带缓存通道
go func() {
fmt.Println("C语言中文网")
done <- 1
}()
<-done
对于带缓存的通道，对通道的第 K 个接收完成操作发生在第 K+C 个发送操作完成之前，其中 C 是通道的缓存大小。虽然通道是带缓存的，但是 main 线程接收完成是在后台线程发送开始但还未完成的时刻，此时打印工作也是已经完成的。
基于带缓存通道，我们可以很容易将打印线程扩展到 N 个，下面的示例是开启 10 个后台线程分别打印：
package main
import (
"fmt"
func main() {
done := make(chan int, 10) // 带10个缓存
// 开N个后台打印线程
for i := 0; i < cap(done); i++ {
go func() {
fmt.Println("C语言中文网")
done <- 1
}()
// 等待N个后台线程完成
for i := 0; i < cap(done); i++ {
<-done
对于这种要等待 N 个线程完成后再进行下一步的同步操作有一个简单的做法，就是使用 sync.WaitGroup 来等待一组事件：
package main
import (
"fmt"
"sync"
func main() {
var wg sync.WaitGroup
// 开N个后台打印线程
for i := 0; i < 10; i++ {
wg.Add(1)
go func() {
fmt.Println("C语言中文网")
wg.Done()
}()
// 等待N个后台线程完成
wg.Wait()
其中 wg.Add(1) 用于增加等待事件的个数，必须确保在后台线程启动之前执行（如果放到后台线程之中执行则不能保证被正常执行到）。当后台线程完成打印工作之后，调用 wg.Done() 表示完成一个事件，main() 函数的 wg.Wait() 是等待全部的事件完成。
关注公众号「站长严长生」，在手机上阅读所有教程，随时随地都能学习。本公众号由C语言中文网站长亲自运营，长期更新，坚持原创。
微信扫码关注公众号
优秀文章
C语言变量的作用域，加深对全局变量和局部变量的理解
C++多继承（多重继承）详解
登录MySQL数据库
Linux mke2fs命令:格式化硬盘（给硬盘写入文件系统）
Python if else对缩进的要求
JS &、|、^和~（逻辑位运算符）
Go语言表达式求值器
MyBatis执行SQL的两种方式
CSS @规则（详细）
找数组的最大值和最小值
精美而实用的网站，分享优质编程教程，帮助有志青年。千锤百炼，只为大作；精益求精，处处斟酌；这种教程，看一眼就倾心。
关于网站 |
关于站长 |
如何完成一部教程 |
公众号 |
联系我们 |
网站地图
Copyright ©2012-2022 biancheng.net, 冀ICP备2022013920号, 冀公网安备13110202001352号
加入微信交流群，一起学习不枯燥。内含一款搜索神器，免费下载全网书籍和视频。