为了账号安全,请及时绑定邮箱和手机立即绑定

等待互斥体而不获取它

等待互斥体而不获取它

Go
LEATH 2022-08-24 10:37:58
我一直在编写一个小型微服务,以便熟悉Go及其并发机制。在我的程序中,我有一个具有状态的结构,并且我想同步该状态,以便多个goroutine能够读取它,但当另一个goroutine正在更新该状态时,则不能。最初,我认为RWMutax是我需要的,但是根据文档,只有一个goroutine可以在任何给定的哀悼中获得读锁定。我要说这句话:“如果一个 goroutine 拿着一个 RWMutex 进行读取,而另一个 goroutine 可能会调用 Lock,那么在释放初始读锁定之前,没有 goroutine 应该能够获得读锁定。有没有办法在不获取锁的情况下等待互斥锁?大致如下:type stateful struct {    state        int    stateMutex   sync.Mutex    beingUpdated bool}type Stateful interface {    GetState() int    SetState(st int)}func createStateful (sa string) stateful {    return server{state: 0, stateMutex: sync.Mutex{}, beingUpdated: false}}func (s *stateful) SetState(st int) {    s.stateMutex.Lock()    s.beingUpdated = true    s.state = st    s.beingUpdated = false    s.stateMutex.Unlock()}func (s *stateful) GetState() bool {    if s.beingUpdated {        // wait for s.stateMutex to be unlocked    }    return s.state}
查看完整描述

1 回答

?
FFIVE

TA贡献1797条经验 获得超6个赞

您可能误读了同步。RWMutex docs:


...锁可以由任意数量的读取器或单个写入器持有。


所以你的代码简化如下:


type stateful struct {

    l     sync.RWMutex // style: place lock above ...

    state int        //        ... the field it protects

}


func (s *stateful) SetState(st int) {

    s.l.Lock()

    defer s.l.Unlock()


    s.state = st

}


func (s *stateful) GetState() int {

    s.l.RLock()

    defer s.l.RUnlock()


    return s.state

}


查看完整回答
反对 回复 2022-08-24
  • 1 回答
  • 0 关注
  • 86 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信