代码之家 › 专栏 › 技术社区 › arash kordi

golang仅在writer进行更改时阻止读卡器

concurrency go

arash kordi · 技术社区 · 7 年前

我有一个作者goroutine和多个读者goroutine。我想在writer更改数据时阻止读卡器。

package main

data []int

func main() {
    m := sync.Mutex{}

    for i := 0; i< 10; i++ {
        go func reader() {
            for {
                m.Lock()
                myData := data
                m.Unlock()
                read_from_data(myData)
            }
        }()
    }

    go func writer() {
        for {
            newData := new_data()
            m.Lock()
            data = newData
            m.Unlock()
            time.Sleep(1 * time.Seconds)
        }
    }
}

我怎样才能做到这一点,而不让读者互相阻塞?

1 回复 | 直到 7 年前

icza 7 年前

这是什么 sync.RWMutex 用于。

它有两种不同的锁定方法: RWMutex.Lock() 对于作者,以及 RWMutex.RLock() 对于读者。(有两种不同的解锁方法,与不同的锁定方法相匹配: RWMutex.Unlock() 和 RWMutex.RUnlock() .)

RWMutex 允许多个读卡器或一个写入器。如果某个写入程序获得了锁,则在该写入程序解锁之前,不允许读卡器(也不允许其他写入程序)。如果读卡器获得读锁,则允许任何其他读卡器(但不允许写入器,直到所有读卡器解锁)。

m := sync.RWMutex{}

for i := 0; i < 10; i++ {
    go func() { // reader
        for {
            m.RLock()
            myData := data
            m.RUnlock()
            read_from_data(myData)
        }
    }()
}

go func() { // writer
    for {
        newData := new_data()
        m.Lock()
        data = newData
        m.Unlock()
        time.Sleep(1 * time.Seconds)
    }
}

推荐文章

a a · 为什么在这个可重入锁示例中需要引用计数?

3 年前

Grant · goroutines有高空闲唤醒电话

3 年前

CapBul · 只有case子句(没有case表达式)和default case的select语句在Golang中做什么?

3 年前

Teho · NodeJs服务器如何处理并发请求?(关于数据库端的问题)

3 年前

plpm · 如何在Python中的进程之间发送和接收消息(通过通道)?

3 年前

hoaz · 如何安全地清理并发映射

7 年前

Ettapp · MySQL/PostgreSQL-这是否可以在事务中执行并行写入?

7 年前

Alanpatchi · int基元类型的volatile声明

7 年前

arash kordi · golang仅在writer进行更改时阻止读卡器

7 年前