Go言语中sync.Cond独霸详解

sync.Cond 可以用来干甚么？言语

Golang 的 sync 包中的 Cond 完成了一种前提变量，可独霸多个 Reader 等待群众成本。霸详

每个 Cond 都邑联络相干一个 Lock ,言语当改削前提或调用 Wait 编制，必须加锁，霸详呵护 Condition。言语 有点近似 Java 中的霸详 Wait 和 NotifyAll。

sync.Cond 前提变量是言语用来调和想要共享成本的那些 goroutine, 当共享成本的外形产生发火改削时，可以被用来赐顾帮衬被互斥锁梗阻的霸详 gorountine。

与 Sync.Mutex 的言语分辨

sync.Cond 基于互斥锁，和互斥锁有甚么分辨 ？霸详

sync.Mutex 但凡用来呵护临界区和共享成本，前提变量 sync.Cond 用来调和想要访谒的言语共享成本。

sync.Cond 独霸处景

有一个协程正在领受数据，霸详其他协程必须等待这个协程领受完数据，言语才调读取到切确的霸详数据。

上述气候下 ，言语假定纯真的独霸 channel 或互斥锁 ，只能有一个协程可以等待，并读取到数据，没编制赐顾帮衬其他协程也读取数据。

这个时辰若何办 ？

• 可以用一个全局变量标识第一个协程可否领受数据终了，剩下的协程几回搜检该变量的值 ，直到读取到数据 。
• 也可成立多个 channel, 每个协程梗阻在一个 Channel 上，由领受数据的协程在数据领受终了后，挨个赐顾帮衬。

然后 Go 中真实内置来一个 sync.Cond 来措置这个问题 。

sync.Cond

// Each Cond has an associated Locker L (often a *Mutex or *RWMutex),// which must be held when changing the condition and// when calling the Wait method.//// A Cond must not be copied after first use.type Cond struct {         noCopy noCopy        // L is held while observing or changing the condition        L Locker        notify  notifyList        checker copyChecker}

可以看到每个 Cond 都邑联络相干一个 锁 L (互斥锁 Mutex, 或读写锁 * RMMutex), 当改削前提或独霸 Wait 的时辰必须求加锁
。

sync.Cond 有哪些编制

NewCond 成立实例

func NewCond(l Locker) *Cond

NewCond 成立实例需求联络相干一个锁 。

具体实例：

cadence := sync.NewCond(&sync.Mutex{ })

Broadcast 播送唤醒全数

// Broadcast wakes all goroutines waiting on c.//// It is allowed but not required for the caller to hold c.L// during the call.func (c *Cond) Broadcast()

Broadcast 唤醒全数等待前提变量 c 的 goroutine
，无需锁呵护
。

具体实例：

go func() {    for range time.Tick(1 * time.Millisecond) {       cadence.Broadcast()   }}()

Signal 唤醒一个协程

// Signal wakes one goroutine waiting on c, if there is any.//// It is allowed but not required for the caller to hold c.L// during the call.func (c *Cond) Signal()

Signal 只唤醒肆意1个等待前提变量 c 的 goroutine，无需锁呵护。 有点近似 Java 中的 Notify

Wait 等待

// Wait atomically unlocks c.L and suspends execution// of the calling goroutine. After later resuming execution,// Wait locks c.L before returning. Unlike in other systems,// Wait cannot return unless awoken by Broadcast or Signal.//// Because c.L is not locked when Wait first resumes, the caller// typically cannot assume that the condition is true when// Wait returns. Instead, the caller should Wait in a loop:////    c.L.Lock()//    for !condition() { //        c.Wait()//    }//    ... make use of condition ...//    c.L.Unlock()//func (c *Cond) Wait()

调用 Wait 会主动释放锁 c.L
，并挂起调用者地址的 goroutine ，是以往后协程会梗阻在 Wait 编制调用的中心。假定其他协程调用了 Signal 或 Broadcast 唤醒了该协程 ，Wait 编制停止梗阻时 ，着从头给 c.L 加锁，并且延续奉行 Wait 后背的代码

代码示例：

c.L.Lock()for !condition() {     c.Wait()}... make use of condition ...c.L.Unlock()

代码示例

package syncimport (   "log"   "sync"   "testing"   "time")var done = falsefunc read(name string, c *sync.Cond) {    c.L.Lock()   for !done {       c.Wait()   }   log.Println(name, "starts reading")   c.L.Unlock()}func write(name string, c *sync.Cond) {    log.Println(name, "starts writing")   time.Sleep(time.Second)   c.L.Lock()   done = true   c.L.Unlock()   log.Println(name, "wakes all")   c.Broadcast()}func TestSyncCond(t *testing.T) {    cond := sync.NewCond(&sync.Mutex{ })   go read("reader1", cond)   go read("reader2", cond)   go read("reader3", cond)   write("writer", cond)   time.Sleep(time.Second * 3)}

运转下场

=== RUN   TestSyncCond
2021/08/26 11:06:48 writer starts writing
2021/08/26 11:06:49 writer wakes all
2021/08/26 11:06:49 reader3 starts reading
2021/08/26 11:06:49 reader2 starts reading
2021/08/26 11:06:49 reader1 starts reading
--- PASS: TestSyncCond (4.01s)
PASS

到此这篇关于Go言语中sync.Cond独霸详解的文章就引见到这了,更多相干Go sync.Cond内容请搜刮完竣下载之前的文章或延续不雅不雅不雅不雅鉴赏上面的相干文章希看大年夜师往后多多支撑完竣下载！