使用 Go 语言的 Channel 替代互斥锁 (Mutex)

碧海醫心

发布时间：2025-07-19 18:28:38

340人浏览过

来源于php中文网

原创

使用 go 语言的 channel 替代互斥锁 (mutex)

本文旨在阐述如何在 Go 语言中使用 Channel 来实现互斥锁的功能。Channel 不仅可以进行数据传递，还具备同步机制，能确保 Goroutine 之间的状态同步。通过示例代码，我们将展示如何利用 Channel 的特性来避免竞态条件，并提供使用空结构体 Channel 优化内存占用的方法。

在并发编程中，互斥锁（Mutex）是一种常用的同步原语，用于保护共享资源，防止多个 Goroutine 同时访问造成数据竞争。然而，Go 语言提供的 Channel 机制，在某些情况下，可以作为互斥锁的替代方案，提供更简洁、更高效的并发控制方式。

Channel 的核心在于其同步特性。当一个 Goroutine 尝试从一个空的 Channel 接收数据时，它会被阻塞，直到有其他 Goroutine 向该 Channel 发送数据。同样，当一个 Goroutine 尝试向一个已满的 Channel 发送数据时，它也会被阻塞，直到有其他 Goroutine 从该 Channel 接收数据。这种阻塞和唤醒机制，天然地提供了同步能力。

我们可以利用带缓冲的 Channel (Buffered Channel) 来模拟互斥锁的行为。创建一个容量为 1 的 Channel，可以将其视为一个“许可证”。 Goroutine 只有成功从 Channel 接收到数据，才能获得访问共享资源的权限；访问完成后，再将数据发送回 Channel，释放“许可证”，允许其他 Goroutine 访问。

以下是一个使用 Channel 替代 Mutex 的示例：

package main

import "fmt"

var global int = 0
var c = make(chan int, 1)

func thread1() {
    <-c // 从 Channel 接收数据，获取“许可证”
    global = 1
    fmt.Println("Thread 1: global =", global)
    c <- 1 // 将数据发送回 Channel，释放“许可证”
}

func thread2() {
    <-c // 从 Channel 接收数据，获取“许可证”
    global = 2
    fmt.Println("Thread 2: global =", global)
    c <- 1 // 将数据发送回 Channel，释放“许可证”
}

func main() {
    c <- 1 // 初始化 Channel，放入一个“许可证”
    go thread1()
    go thread2()

    // 等待 Goroutine 执行完成，避免程序过早退出
    var input string
    fmt.Scanln(&input)
}

在这个例子中，c 是一个容量为 1 的 chan int。main 函数首先向 c 发送一个值 1，相当于初始化了“许可证”。 thread1 和 thread2 在访问 global 变量之前，都必须先从 c 接收数据，获得“许可证”，访问完成后，再将数据发送回 c，释放“许可证”。这样就保证了 global 变量在同一时刻只能被一个 Goroutine 访问，避免了竞态条件。

使用空结构体 Channel 优化内存占用

英特尔AI工具

英特尔AI与机器学习解决方案

下载

在上述示例中，我们使用了 chan int，但实际上，我们并不关心 Channel 中传递的具体数值，只需要利用 Channel 的同步特性即可。因此，可以使用 chan struct{} 来替代 chan int，以减少内存占用。空结构体 struct{} 不占用任何内存空间，使用 chan struct{} 可以有效地降低程序的内存消耗。

修改后的代码如下：

package main

import "fmt"

var global int = 0
var c = make(chan struct{}, 1)

func thread1() {
    <-c // 从 Channel 接收数据，获取“许可证”
    global = 1
    fmt.Println("Thread 1: global =", global)
    c <- struct{}{} // 将数据发送回 Channel，释放“许可证”
}

func thread2() {
    <-c // 从 Channel 接收数据，获取“许可证”
    global = 2
    fmt.Println("Thread 2: global =", global)
    c <- struct{}{} // 将数据发送回 Channel，释放“许可证”
}

func main() {
    c <- struct{}{} // 初始化 Channel，放入一个“许可证”
    go thread1()
    go thread2()

    // 等待 Goroutine 执行完成，避免程序过早退出
    var input string
    fmt.Scanln(&input)
}

在这个修改后的版本中，c 的类型变为 chan struct{}，并且我们使用 struct{}{} 来初始化 Channel 和发送数据。这与之前的版本功能相同，但内存占用更小。

注意事项和总结