温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

锁/竞争(互斥锁、读写锁、原子锁)

发布时间:2020-06-22 15:37:02 来源:网络 阅读:674 作者:梁十八 栏目:编程语言

a. import(“sync”)
b. 互斥锁, var mu sync.Mutex (只有一个释放之后,下一个才能进去)(sync.Mutex类型只有两个公开的指针方法:Lock、Unlock)
c. 读写锁, var mu sync.RWMutex(读不锁,只有写才锁)
d.原子锁,import "sync/atomic"


比如map,文件等被多个goroutine修改,则要做好锁。
只读无需加锁

用go build -race xxx.go来编译,并运行二进制文件来查看竞争关系


互斥锁举例:

a := make(map[int]int, 5)
    a[0] = 10
    fmt.Println(a)
    for i := 0; i < 2; i++ {
        go func(b map[int]int){
            //设置互斥锁
            lock.Lock()
            a[0] = rand.Intn(100)
            lock.Unlock()
        }(a)
    }
    //互斥锁不读还是写,都要设置才能确保不竞争
    lock.Lock()
    fmt.Println(a)
    lock.Unlock()

读写锁(包括原子锁)举例:

package main

import (
    "sync"
    "fmt"
    "math/rand"
    "time"
    "sync/atomic"
)

var rwLock sync.RWMutex

func main() {

    var count int32
    //读写锁
    a := make(map[int]int, 5)
    a[0] = 10
    fmt.Println(a)
    for i := 0; i < 2; i++ {
        go func(b map[int]int){
            //写的锁是Lock
            rwLock.Lock()
            a[0] = rand.Intn(100)
            rwLock.Unlock()
        }(a)
    }
    for i := 0; i < 100; i++ {
        go func(b map[int]int){
            //读的锁是RLock
            rwLock.RLock()
            fmt.Println(a)
            //原子锁引用赋值count,每次加一
            atomic.AddInt32(&count, 1)
            rwLock.RUnlock()
        }(a)
    }
    time.Sleep(time.Second)
    //输出原子锁次数也要有固定写法
    fmt.Println(atomic.LoadInt32(&count))
}

锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)


锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)
锁/竞争(互斥锁、读写锁、原子锁)

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI