开发者

golang sync.Cond同步机制运用及实现

开发者 https://www.devze.com 2023-11-21 12:09 出处:网络 作者: lincoln_hlf1
目录sync.Condsync.Cond 源码分析其他同步方式的实现sync.Cond Go同步通信channel sync.Cond 提供了三个方法:Wait()、Signal()、Broadcast(),它们的用法如下:
目录
  • sync.Cond
    • sync.Cond 源码分析
    • 其他同步方式的实现

sync.Cond

Go同步通信channel

sync.Cond 提供了三个方法:Wait()、Signal()、Broadcast(),它们的用法如下:

  • Wait():阻塞当前的 gorouti编程客栈ne,等待唤起。www.devze.com
  • Signal():唤起一个阻塞的 goroutine。
  • Broadcast():唤起所有阻塞的 goroutine。

通过上面的方法描述,我们就可以简单的实现一个任务池功能:先批量的创建 goroutine,然后调用 sync.Cond 的 Wait() 方法让其阻塞的等待。

当有一个任务到来时,则通过 Signal() 唤起刚刚在阻塞的某一个 goroutine,去执行任务。

通过任务池功能,我们发现 sync.Cond 的运用很简单,但 Go 官方并不推荐我们使用 sync.Cond 来实现协程间的同步通信

因为它并不符合 Gjso 官方 “通过通信来共享内存” 的设计思想,当场景复杂时,则会耦合各个业务功能。

sync.Cond 源码分析

我们来看下 sync.Cond 的结构体,代码在 /sr/sync/cond.go 下:

type Cond struct {
    noCopy noCopy       // 不可复制
    L Locker            // 锁
    notify  notifyList  // 通知唤起列表
    checker copyChecker // 复制检测
}

可以看到 Cond 上有 notify 列表,而这正是维护了需要唤起的 g编程客栈oroutine 列表。

当我们调用 Wait() 方法的时候就会维护当前 goroutine 到对应的 notifyList 里:

func (c *Cond) Wait() {
    c.checker.check()
    t := runtime_notifyListAdd(&c.notify) // 将当前 goroutine 添加到 notifyList 里
    c.L.Unlock()
    runtime_notifyListWait(&c.notify, t) // 阻塞等待
    c.L.Lock()
}

当有其他协程调用了 Signal 或 Broadcast 方法时,则会通过runtime_notifyListNotifyOneruntime_notifyListNotifyAll方法来唤起一个或多个 goroutine。

其他同步方式的实现

前面提到到 sync.Cond 并不被推荐作为协同通信手段,那如果要实现它的单播、广播效果,该怎么弄呢?

其实也很简单,如果我们要实现jMthqM单播效果,那么只需要通过阻塞的监听 channel 信号即可。

如果要实现广播唤起效果,只需要利用 context 的链式取消特性,也能达到该效果。

以上就是golang sync.Cond同步机制运用及实现的详细内容,更多关于golang sync.Cond同步机制的资料请关注编程客栈(www.devze.com)其它相关文章!

0

精彩评论

暂无评论...
验证码 换一张
取 消

关注公众号