Go 语言中的并发模型的选择有哪些？-Golang-PHP中文网

Go 语言中的并发模型的选择有哪些？

PHPz

发布： 2023-06-10 13:46:37

原创

1062人浏览过

随着互联网时代的到来，人们对程序的并发性能要求日益提高。而在开发高并发程序的过程中，选择合适的并发模型显得尤为重要。本文将介绍在 go 语言中几种常用的并发模型，以及它们的优缺点和适用场景。

Goroutine 和 Channel

Goroutine 和 Channel 是 Go 语言中最基础、最常用的并发模型。Goroutine 是轻量级线程，可以在并发执行的同时高效地利用 CPU 资源。Channel 是一种用于 Goroutine 之间通信的方式，通过 Channel 可以方便地传递数据，从而实现并发控制和同步。

在 Go 语言中，可以使用关键字 go 来启动一个 Goroutine：

go func() {
    // Goroutine 执行的代码
}()

登录后复制

通过使用 Channel，可以实现不同 Goroutine 之间的通信和同步：

ch := make(chan int)
go func() {
    ch <- 1 // 向通道发送数据
}()
x := <-ch // 从通道接收数据

登录后复制

优点：

轻量级，启动和销毁的代价极小。
通过 Channel 实现通信可以避免使用互斥锁和条件变量，编写清晰、简单的代码。
Channel 的阻塞特性可以实现同步，可以避免竞争条件的出现。

缺点：

依赖 Channel，不适合处理一些无需通信的任务。
可能存在死锁问题。
在处理大量的 IO 访问时性能可能不如一些专用的并发模型。

适用场景：

任务需要相互通信、任务之间有依赖关系的情况，常见的如生产者-消费者模式。
要求高并发、任务处理时间较短的场景。

WaitGroup 和 Mutex

WaitGroup 和 Mutex 是 Go 语言中另一种常用的并发模型。WaitGroup 可以用于等待一组 Goroutine 执行完毕，而 Mutex 则用于实现锁机制，防止共享资源被并发访问。

在使用 WaitGroup 时，可以通过 Add() 方法增加计数器的值，通过 Done() 方法减少计数器的值，并通过 Wait() 方法等待计数器变为 0：

var wg sync.WaitGroup
for i := 0; i < num; i++ {
    wg.Add(1) // 增加计数器的值
    go func() {
        // Goroutine 执行的代码
        wg.Done() // 减少计数器的值
    }()
}
wg.Wait() // 等待计数器变为 0

登录后复制

在使用 Mutex 时，可以通过 Lock() 和 Unlock() 方法实现对共享资源的互斥访问：

var mu sync.Mutex
mu.Lock()
// 访问共享资源的代码
mu.Unlock()

登录后复制

优点：

WaitGroup 可以方便地等待一组 Goroutine 执行完毕。
Mutex 可以防止共享资源被并发访问，保证程序的正确性。
通过 WaitGroup 和 Mutex 可以灵活地控制并发量和同步操作。

缺点：

代码复杂度较高。
可能存在竞态条件。

适用场景：

需要等待一组 Goroutine 执行完毕的情况。
对共享资源需要进行互斥访问的情况。

线程池

线程池是一种常见的并发模型，可以在程序启动时就创建一组线程，当需要并发执行任务时，从线程池中获取一个线程来执行。线程池可以避免频繁地创建和销毁线程，节省资源开销。

Kotlin Android 中文开发帮助文档 PDF版

这本书并不是一本语言参考书，但它是一个Android开发者去学习Kotlin并且使用在自己项目中的一个工具。我会通过使用一些语言特性和有趣的工具和库来解决很多我们在日常生活当中都会遇到的典型问题。这本书是非常具有实践性的，所以我建议你在电脑面前跟着我的例子和代码实践。无论何时你都可以在有一些想法的时候深入到实践中去。这本书适合你吗？写这本书是为了帮助那些有兴趣使用Kotlin语言来进行开发的Android开发者。如果你符合下面这些情况，那这本书是适合你的：你有相关Android开发和Andro

查看详情

在 Go 语言中可以使用标准库中的 goroutine 池和第三方库中的 go-workerpool 库来实现线程池。其中，goroutine 池是使用本地变量实现的一种简单实现方式：

workerPool := make(chan chan Task, MaxWorkers)
for i := 0; i < MaxWorkers; i++ {
    worker := NewWorker(workerPool)
    worker.Start()
}
go func() {
    for {
        select {
        case task := <-taskQueue:
            go func(task Task) {
                // 执行任务的代码
            }(task)
        }
    }
}()

登录后复制

优点：

可以控制并发数，避免资源浪费。
可以重复利用线程，减少创建和销毁的代价。
适用于大量的 IO 密集型操作。

缺点：

代码相对复杂。
需要手动实现对任务的调度。

适用场景：

大量的 IO 密集型操作。
并发量需要控制的情况。

Actor 模型

Actor 模型是一种用于编写可并发程序的数学模型，它由主要由三个部分组成：Actor、信箱、消息。Actor 可以看作是一种并发执行的对象，每个 Actor 有一个或多个信箱，用于接收消息。消息是用于在 Actor 之间传递信息的一种机制。

在 Go 语言中，可以使用第三方库 go-actor 实现 Actor 模型：

type HelloActor struct {}

type Hello struct {
    Who string
    C   chan string
}

func (hello HelloActor) Receive(context actor.Context) {
    switch msg := context.Message().(type) {
    case Hello:
        context.Respond(HelloResponse{Message: "Hello, " + msg.Who + "!"})
    }
}

system := actor.NewActorSystem()
helloActor := system.ActorOf(actor.PropsFromProducer(func() actor.Actor { return &HelloActor{} }), "hello")

respChan := make(chan string)
helloActor.Tell(Hello{Who: "Alice", C: respChan})

response := <-respChan
fmt.Println(response)

登录后复制

优点：