Go语言中的并发模型简介

Go 语言的并发模型主要基于 goroutines 和 channels。下面我将分别解释它们是如何工作的，并提供一个简单的例子。

1. Goroutines

Goroutines 是 Go 语言实现并发的核心。它们是 Go 程序中轻量级的执行线程，由 Go 运行时管理。Goroutine 的调度是由 Go 运行时进行的，与操作系统的线程调度是分开的。

创建一个 goroutine 非常简单，只需要在函数调用前加上 go 关键字：

1

go myFunction()

2. Channels

Channels 用于在不同的 goroutines 之间进行通信。它们可以传递数据，并且可以用来同步 goroutines。Channels 可以是带缓冲的（buffered）或不带缓冲的（unbuffered）。

创建一个 channel：

1
2
3
4
5

// 创建一个不带缓冲的 channel
ch := make(chan int)

// 创建一个带缓冲的 channel，可以存储 5 个 int 类型的数据
chBuffered := make(chan int, 5)

使用 channel 传递数据：

1
2

ch <- 42 // 发送数据到 channel
value := <-ch // 从 channel 接收数据

3. 并发模型示例

下面是一个使用 goroutines 和 channels 的简单并发程序示例：

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

package main

import (
	"fmt"
	"time"
)

// 一个简单的函数，打印接收到的值
func printValues(ch chan int) {
	for v := range ch {
		fmt.Println(v)
	}
}

func main() {
	// 创建一个 channel
	ch := make(chan int)

	// 创建一个 goroutine 来打印从 channel 接收到的值
	go printValues(ch)

	// 发送一些数据到 channel
	for i := 0; i < 5; i++ {
		ch <- i
	}

	// 关闭 channel，通知接收端没有更多数据
	close(ch)

	// 给 goroutine 一些时间来打印剩余的数据
	time.Sleep(1 * time.Second)
}

在这个例子中，主函数创建了一个 channel 和一个 goroutine。goroutine 通过 printValues 函数不断从 channel 接收数据并打印。主函数向 channel 发送数据，并在发送完毕后关闭 channel。这会通知 goroutine 没有更多的数据要发送，goroutine 随后会退出。

这个简单的模型展示了 Go 语言并发编程的基本思想：通过 goroutines 来实现并行执行，通过 channels 来同步和通信。这种模型使得编写并发程序变得简单且高效。