当前位置：首页 > ops >正文

对golang中CSP的理解

ops 2025/9/2 16:48:45

概念：

CSP模型，即通信顺序进程模型，是由英国计算机科学家C.A.R. Hoare于1978年提出的。该模型强调进程之间通过通道（channel）进行通信，并通过消息传递来协调并发执行的进程。CSP模型的核心思想是“不要通过共享内存来通信，而要通过通信来共享内存”。这一思想有效地避免了传统并发编程中常见的竞态条件和死锁问题。

我的理解是一份数据不能由多个协程同时持有：

1、对于无缓冲chan，一份数据只能同时由一个协程持有。

如果没有数据接收者，发送者阻塞。

如果阻塞后出现了数据接收者，将数据转交给接收者之后发送者才能从阻塞中返回。

如果有数据接收者在等待，发送者不用阻塞，将数据转交给接收者之后立刻返回。

2、对于带缓冲chan，一份数据或者在缓冲中或者由一个协程持有。

如果缓冲满（没有接收者或接收者慢），发送者阻塞。

只有在数据接收者取走缓冲中的数据后，缓冲有剩余容量，阻塞的发送者才能返回。

如果有多个接收者，一份数据只能被一个接收者接收。

示例程序：两个协程交替打印奇偶数：

使用不带缓冲的chan，如果发送者在没有接收者接收的情况下也可以返回的话，就会出现争抢数据，也就不满足奇偶打印的要求。

import ("fmt""sync""time"
)func main() {var ch = make(chan int)var wg sync.WaitGroupwg.Add(2)go func() {defer wg.Done()for v1 := range ch {fmt.Println(time.Now().Format(time.TimeOnly), "go1:", v1)ch <- v1 + 1time.Sleep(time.Second)}}()go func() {defer wg.Done()for v2 := range ch {fmt.Println(time.Now().Format(time.TimeOnly), "go2:", v2)ch <- v2 + 1time.Sleep(time.Second)}}()ch <- 1wg.Wait()
}

控制台输出：