go语言中如何实现同步操作呢

客官°小女子只卖身不卖艺 2024-03-17 00:27 25阅读 0赞

## 1. 简介 ##

本文探讨了并发编程中的同步操作，讲述了为何需要同步以及两种常见的实现方式：`sync.Cond`和通道。通过比较它们的适用场景，读者可以更好地了解何时选择使用不同的同步方式。本文旨在帮助读者理解同步操作的重要性以及选择合适的同步机制来确保多个协程之间的正确协调和数据共享的一致性。

## 2. 为什么需要同步操作 ##

#### 2.1 为什么需要同步操作 ####

这里举一个简单的图像处理场景来说明。任务A负责加载图像，任务B负责对已加载的图像进行处理。这两个任务将在两个并发协程中同时启动，实现并行执行。然而，这两个任务之间存在一种依赖关系：只有当图像加载完成后，任务B才能安全地执行图像处理操作。

在这种情况下，我们需要对这两个任务进行协调和同步。任务B需要确保在处理已加载的图像之前，任务A已经完成了图像加载操作。通过使用适当的同步机制来确保任务B在图像准备就绪后再进行处理，从而避免数据不一致性和并发访问错误的问题。

事实上，在我们的开发过程中，经常会遇到这种需要同步的场景，所以了解同步操作的实现方式是必不可少的，下面我们来仔细介绍。

#### 2.2 如何实现同步操作呢 ####

通过上面的例子，我们知道当多协程任务**存在依赖关系**时，同步操作是必不可免的，那如何实现同步操作呢?这里的一个简单想法，便是采用一个简单的条件变量，不断采用轮询的方式来检查事件是否已经发生或条件是否满足，此时便可实现简单的同步操作。代码示例如下:

package main
    
    import (
            "fmt"
            "time"
    )
    
    var condition bool
    
    func waitForCondition() {
           for !condition {
                 // 轮询条件是否满足
                 time.Sleep(time.Millisecond * 100)
           }
           fmt.Println("Condition is satisfied")
    }
    
    func main() {
            go waitForCondition()
    
            time.Sleep(time.Second)
            condition = true // 修改条件
    
            time.Sleep(time.Second)
    }

在上述代码中，`waitForCondition` 函数通过轮询方式检查条件是否满足。当条件满足时，才继续执行下去。

但是这种轮训的方式其实存在一些缺点，首先是资源浪费，轮询会消耗大量的 CPU 资源，因为协程需要不断地执行循环来检查条件。这会导致 CPU 使用率升高，浪费系统资源，其次是延迟，轮询方式无法及时响应条件的变化。如果条件在循环的某个时间点满足，但轮询检查的时机未到，则会延迟对条件的响应。最后轮询方式可能导致协程的执行效率降低。因为协程需要在循环中不断检查条件，无法进行其他有意义的工作。

既然通过轮训一个条件变量来实现同步操作存在这些问题。那go语言中，是否存在更好的实现方式，可以避免轮询方式带来的问题，提供更高效、及时响应的同步机制。其实是有的，`sync.Cond` 和`channel`便是两个可以实现同步操作的原语。

## 3.实现方式 ##

#### 3.1 sync.Cond实现同步操作 ####

使用`sync.Cond`实现同步操作的方法，可以参考[sync.Cond][] 这篇文章，也可以按照可以按照以下步骤进行：

1.  创建一个条件变量：使用`sync.NewCond`函数创建一个`sync.Cond`类型的条件变量，并传入一个互斥锁作为参数。
2.  在等待条件满足的代码块中使用`Wait`方法：在需要等待条件满足的代码块中，调用条件变量的`Wait`方法，这会使当前协程进入等待状态，并释放之前获取的互斥锁。
3.  在满足条件的代码块中使用`Signal`或`Broadcast`方法：在满足条件的代码块中，可以使用`Signal`方法来唤醒一个等待的协程，或者使用`Broadcast`方法来唤醒所有等待的协程。

下面是一个简单的例子，演示如何使用`sync.Cond`实现同步操作:

package main
    
    import (
            "fmt"
            "sync"
            "time"
    )
    
    func main() {
            var cond = sync.NewCond(&sync.Mutex{})
            var ready bool
    
            // 等待条件满足的协程
            go func() {
                    fmt.Println("等待条件满足...")
                    cond.L.Lock()
                    for !ready {
                            cond.Wait()
                    }
                    fmt.Println("条件已满足")
                    cond.L.Unlock()
            }()
    
            // 模拟一段耗时的操作
            time.Sleep(time.Second)
    
            // 改变条件并通知等待的协程
            cond.L.Lock()
            ready = true
            cond.Signal()
            cond.L.Unlock()
    
            // 等待一段时间，以便观察结果
            time.Sleep(time.Second)
    }

在上面的例子中，我们创建了一个条件变量`cond`，并定义了一个布尔型变量`ready`作为条件。在等待条件满足的协程中，通过调用`Wait`方法等待条件的满足。在主协程中，通过改变条件并调用`Signal`方法来通知等待的协程条件已满足。在等待协程被唤醒后，输出"条件已满足"的消息。

通过使用`sync.Cond`，我们实现了一个简单的同步操作，确保等待的协程在条件满足时才会继续执行。这样可以避免了不必要的轮询和资源浪费，提高了程序的效率。

#### 3.2 channel实现同步操作 ####

当使用通道（channel）实现同步操作时，可以利用通道的阻塞特性来实现协程之间的同步。下面是一个简单的例子，演示如何使用通道实现同步操作：

package main
    
    import (
            "fmt"
            "time"
    )
    
    func main() {
            // 创建一个用于同步的通道
            done := make(chan bool)
    
            // 在协程中执行需要同步的操作
            go func() {
                    fmt.Println("执行一些操作...")
                    time.Sleep(time.Second)
                    fmt.Println("操作完成")
    
                    // 向通道发送信号，表示操作已完成
                    done <- true
            }()
    
            fmt.Println("等待操作完成...")
            // 阻塞等待通道接收到信号
            <-done
            fmt.Println("操作已完成")
    }

在上面的例子中，我们创建了一个通道`done`，用于同步操作。在执行需要同步的操作的协程中，首先执行一些操作，然后通过向通道发送数据`done <- true`来表示操作已完成。在主协程中，我们使用`<-done`来阻塞等待通道接收到信号，表示操作已完成。

通过使用通道实现同步操作，我们利用了通道的阻塞特性，确保在操作完成之前，主协程会一直等待。一旦操作完成并向通道发送了信号，主协程才会继续执行后续的代码。基于此实现了同步操作。

#### 3.3 实现方式回顾 ####

从上面的介绍来看，`sync.Cond`或者`channel`都可以用来实现同步操作。

但由于它们是不同的并发原语，因此在代码编写和理解上可能会有一些差异。条件变量是一种在并发编程中常用的同步机制，而通道则是一种更通用的并发原语，可用于实现更广泛的通信和同步模式。

在选择并发原语时，我们应该考虑到代码的可读性、可维护性和性能等因素。有时，使用条件变量可能是更合适和直观的选择，而在其他情况下，通道可能更适用。了解不同并发原语的优势和限制，并根据具体需求做出适当的选择，是编写高质量并发代码的关键。

## 4. channel适用场景说明 ##

事实上，`channel`并不是被专门用来实现同步操作，而是基于`channel`中阻塞等待的特性，从而来实现一些简单的同步操作。虽然`sync.Cond`是专门设计来实现同步操作的，但是在某些场景下，使用通道比使用 `sync.Cond`更为合适。

其中一个最典型的例子，便是任务的有序执行，使用channel，能够使得任务的同步和顺序执行变得更加直观和可管理。下面通过一个示例代码，展示如何使用通道实现任务的有序执行：

package main
    
    import "fmt"
    
    func taskA(waitCh chan<- string, resultCh chan<- string) {
            // 等待开始执行
            <- waitCh
            
            // 执行任务A的逻辑
            // ...
            // 将任务A的结果发送到通道
            resultCh <- "任务A完成"
    }
    
    func taskB(waitCh <-chan string, resultCh chan<- string) {
            // 等待开始执行
            resultA := <-waitCh
    
            // 根据任务A的结果执行任务B的逻辑
            // ...
    
            // 将任务B的结果发送到通道
            resultCh <- "任务B完成"
    }
    
    func taskC(waitCh <-chan string, resultCh chan<- string) {
            // 等待任务B的结果
            resultB := <-waitCh
    
            // 根据任务B的结果执行任务C的逻辑
            // ...
            resultCh <- "任务C完成"
    }
    
    func main() {
            // 创建用于任务之间通信的通道
            beginChannel := make(chan string)
            channelA := make(chan string)
            channelB := make(chan string)
            channelC := make(chan string)
            
            beginChannel <- "begin"
            // 启动任务A
            go taskA(beginChannel, channelA)
    
            // 启动任务B
            go taskB(channelA, channelB)
    
            // 启动任务C
            go taskC(channelB,channelC)
    
            // 阻塞主线程，等待任务C完成
            select {}
    
            // 注意：上述代码只是示例，实际情况中可能需要适当地添加同步操作或关闭通道的逻辑
    }

在这个例子中，我们启动了三个任务，并通过通道进行它们之间的通信来保证执行顺序。任务A等待`beginChannel`通道的信号，一旦接收到信号，任务A开始执行并将结果发送到`channelA`通道。其他任务，比如任务B，等待任务A完成的信号，一旦接收到`channelA`通道的数据，任务B开始执行。同样地，任务C等待任务B完成的信号，一旦接收到`channelB`通道的数据，任务C开始执行。通过这种方式，我们实现了任务之间的有序执行。

相对于使用`sync.Cond`的实现方式来看，通过使用通道，在任务之间进行有序执行时，代码通常更加简洁和易于理解。比如上面的例子，我们可以很清楚得识别出来，任务的执行顺序为 任务A ---> 任务B --> 任务C。

其次通道可以轻松地添加或删除任务，并调整它们之间的顺序，而无需修改大量的同步代码。这种灵活性使得代码更易于维护和演进。也是以上面的代码例子为例，假如现在需要修改任务的执行顺序，将其执行顺序修改为 任务A ---> 任务C ---> 任务B，只需要简单调整下顺序即可，具体如下：

func main() {
            // 创建用于任务之间通信的通道
            beginChannel := make(chan string)
            channelA := make(chan string)
            channelB := make(chan string)
            channelC := make(chan string)
            
            beginChannel <- "begin"
            // 启动任务A
            go taskA(beginChannel, channelA)
    
            // 启动任务B
            go taskB(channelC, channelB)
    
            // 启动任务C
            go taskC(channelA,channelC)
    
            // 阻塞主线程，等待任务C完成
            select {}
    
            // 注意：上述代码只是示例，实际情况中可能需要适当地添加同步操作或关闭通道的逻辑
    }

和之前的唯一区别，只在于任务B传入的waitCh参数为channelC，任务C传入的waitCh参数为channelA，做了这么一个小小的变动，便实现了任务执行顺序的调整，非常灵活。

最后，相对于sync.Cond，通道提供了一种安全的机制来实现任务的有序执行。由于通道在发送和接收数据时会进行隐式的同步，因此不会出现数据竞争和并发访问的问题。这可以避免潜在的错误和 bug，并提供更可靠的同步操作。

总的来说，如果是任务之间的简单协调，比如任务执行顺序的协调同步，通过通道来实现是非常合适的。通道提供了简洁、可靠的机制，使得任务的有序执行变得灵活和易于维护。

## 5. sync.Cond适用场景说明 ##

在任务之间的简单协调场景下，使用channel的同步实现，相对于sync.Cond的实现是更为简洁和易于维护的，但是并非意味着sync.Cond就无用武之地了。在一些相对复杂的同步场景下，sync.Cond相对于channel来说，表达能力是更强的，而且是更为容易理解的。因此，在这些场景下，虽然使用channel也能够起到同样的效果，使用sync.Cond可能相对来说也是更为合适的，即使sync.Cond使用起来更为复杂。下面我们来简单讲述下这些场景。

#### 5.1 精细化条件控制 ####

对于具有复杂的等待条件和需要精细化同步的场景，使用`sync.Cond`是一个合适的选择。它提供了更高级别的同步原语，能够满足这种特定需求，并且可以确保线程安全和正确的同步行为。

下面举一个简单的例子，有一个主协程负责累加计数器的值，而存在多个等待协程，每个协程都有自己独特的等待条件。等待协程需要等待计数器达到特定的值才能继续执行。

对于这种场景，使用`sync.Cond`来实现是更为合适的选择。`sync.Cond`提供了一种基于条件的同步机制，可以方便地实现协程之间的等待和通知。使用`sync.Cond`，主协程可以通过调用`Wait`方法等待条件满足，并通过调用`Broadcast`或`Signal`方法来通知等待的协程。等待的协程可以在条件满足时继续执行任务。

相比之下，使用通道来实现可能会更加复杂和繁琐。通道主要用于协程之间的通信，并不直接提供条件等待的机制。虽然可以通过在通道中传递特定的值来模拟条件等待，但这通常会引入额外的复杂性和可能的竞争条件。因此，在这种情况下，使用`sync.Cond`更为合适，可以更直接地表达协程之间的条件等待和通知，代码也更易于理解和维护。下面来简单看下使用`sync.Cond`实现:

package main
    
    import (
            "fmt"
            "sync"
    )
    
    var (
            counter int
            cond    *sync.Cond
    )
    
    func main() {
            cond = sync.NewCond(&sync.Mutex{})
    
            // 启动等待协程
            for i := 0; i < 5; i++ {
                    go waitForCondition(i)
            }
    
            // 模拟累加计数器
            for i := 1; i <= 10; i++ {
                    // 加锁，修改计数器
                    cond.L.Lock()
                    counter += i
                    fmt.Println("Counter:", counter)
              
                    cond.L.Unlock()
                    
                    cond.Broadcast()
            }
    }
    
    func waitForCondition(id int) {
            // 加锁，等待条件满足
            cond.L.Lock()
            defer cond.L.Unlock()
    
            // 等待条件满足
            for counter < id*10 {
                 cond.Wait()
            }
    
            // 执行任务
            fmt.Printf("Goroutine %d: Counter reached %d\n", id, id*10)
    }

在上述代码中，主协程使用`sync.Cond`的`Wait`方法等待条件满足时进行通知，而等待的协程通过检查条件是否满足来决定是否继续执行任务。每个协程执行的计数器值条件都不同，它们会等待主协程累加的计数器值达到预期的条件。一旦条件满足，等待的协程将执行自己的任务。

通过使用`sync.Cond`，我们可以实现多个协程之间的同步和条件等待，以满足不同的执行条件。

因此，对于具有复杂的等待条件和需要精细化同步的场景，使用`sync.Cond`是一个合适的选择。它提供了更高级别的同步原语，能够满足这种特定需求，并且可以确保线程安全和正确的同步行为。

#### 5.2 需要反复唤醒所有等待协程 ####

这里还是以上面的例子来简单说明，主协程负责累加计数器的值，并且有多个等待协程，每个协程都有自己独特的等待条件。这些等待协程需要等待计数器达到特定的值才能继续执行。在这种情况下，每当主协程对计数器进行累加时，由于无法确定哪些协程满足执行条件，需要唤醒所有等待的协程。这样，所有的协程才能判断是否满足执行条件。如果只唤醒一个等待协程，那么可能会导致另一个满足执行条件的协程永远不会被唤醒。

因此，在这种场景下，每当计数器累加一个值时，都需要唤醒所有等待的协程，以避免某个协程永远不会被唤醒。这种需要重复调用`Broadcast`的场景并不适合使用通道来实现，而是最适合使用`sync.Cond`来实现同步操作。

通过使用`sync.Cond`，我们可以创建一个条件变量，协程可以使用`Wait`方法等待特定的条件出现。当主协程累加计数器并满足等待条件时，它可以调用`Broadcast`方法唤醒所有等待的协程。这样，所有满足条件的协程都有机会继续执行。

因此，在这种需要重复调用`Broadcast`的同步场景中，使用`sync.Cond`是最为合适的选择。它提供了灵活的条件等待和唤醒机制，确保所有满足条件的协程都能得到执行的机会，从而实现正确的同步操作。

## 6. 总结 ##

同步操作在并发编程中起着关键的作用，用于确保协程之间的正确协调和共享数据的一致性。在选择同步操作的实现方式时，我们有两个常见选项：使用`sync.Cond`和通道。

使用`sync.Cond`和通道的方式提供了更高级、更灵活的同步机制。`sync.Cond`允许协程等待特定条件的出现，通过`Wait`、`Signal`和`Broadcast`方法的组合，可以实现复杂的同步需求。通道则提供了直接的通信机制，通过发送和接收操作进行隐式的同步，避免了数据竞争和并发访问错误。

选择适当的同步操作实现方式需要考虑具体的应用场景。对于简单的同步需求，可以使用通道方式。对于复杂的同步需求，涉及共享数据的操作，使用`sync.Cond`和可以提供更好的灵活性和安全性。

通过了解不同实现方式的特点和适用场景，可以根据具体需求选择最合适的同步机制，确保并发程序的正确性和性能。

来源：[go语言中如何实现同步操作呢 - 菜鸟额 - 博客园 (cnblogs.com)][go_ - _ - _ _cnblogs.com]

[sync.Cond]: https://juejin.cn/post/7212270321621483578
[go_ - _ - _ _cnblogs.com]: https://www.cnblogs.com/chenjiazhan/p/17436995.html