码迷,mamicode.com
首页 > 编程语言 > 详细

go语言sync.Cond

时间:2020-07-30 01:33:46      阅读:89      评论:0      收藏:0      [点我收藏+]

标签:多个   pac   消费   ring   就会   经典   模式   好的   mutex   

sync.Cond 是一个事件通知,类似于java中的conditional 或者 wait/notify 机制。

它有一个重要的作用是,协程之间通过锁进行协调的时候,其中一个协程等待的时候,可以释放锁和资源,并且能够及时完成准备工作。

比如经典的生产者消费,例如有一个队列,只有大小为1,生产者需要等待消费者完成消费,才能继续存放。

package main

import (
	"fmt"
	"sync"
	"time"
)

func main() {
	cond := sync.NewCond(&sync.Mutex{})
	msg := make([]string, 1)
	var sended bool
	go func() {
		for {
			time.Sleep(time.Second)
			cond.L.Lock()
			for !sended {
				cond.Wait()
			}
			fmt.Printf("get msg %s\n" , msg[0])
			sended = false
			cond.Signal()
			cond.L.Unlock()
		}
	}()
	go func() {
		for {
			time.Sleep(time.Second)
			cond.L.Lock()
			for sended {
				cond.Wait()
			}
			s := fmt.Sprint("time is ", time.Now().String())
			msg[0]= s
			fmt.Printf("put in msg:%s\n", s)
			sended = true
			cond.Signal()
			cond.L.Unlock()
		
		}
	}()
	time.Sleep(time.Second* 50)
}

它的模式是

cond.L.Lock()
for 判断条件 {
	cond.Wait()
}
//执行任务
cond.L.Unlock()

另外一个地方当条件满足时,就会cond.Signal(),但是signal方法只会唤醒一个协程,如果真实场景下是多个协程中一部分需要被唤醒,就**必须要用 **cond.Broadcast(), 相当于notifyAll()。

通常唤醒的地方,也是在使用临界区的资源,所以唤醒的地方也会写成如下模式

cond.L.Lock()
// 执行任务
cond.Broadcast()
cond.L.Unlock()

相比较于 notify 的用法宽松的地方是, Broadcast 和Signal 方法不需要放在锁内。而wait条件因为已经包装在for循环内,就可以放心的Broadcast

由于上面的示例是互相唤醒,因此写法如下:

cond.L.Lock()
for 判断条件 {
	cond.Wait()
}
cond.Broadcast()
cond.L.Unlock()

虽然channel也可以用于这个场景,但是cond 在一些简化的场景下,可以取得较好的性能。

go语言sync.Cond

标签:多个   pac   消费   ring   就会   经典   模式   好的   mutex   

原文地址:https://www.cnblogs.com/shalk/p/13401403.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!