golang-互斥锁

爱吃豆包 · · 937 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

互斥量(锁) 在go语言里面很少用,但是也提供支持 !

互斥量的概念!go语言提供的锁:Mutex (sync.Mutex)

go 语言提供了原子类型的操作,在 sync/atomic 包下
比如 atomic.AddInt32() 就是累加操作, go 语言提供的
累加操作,就算多个协程同时累加,也是安全,优先使用 go 语言提供的!

在这里手动实现一个互斥量, 用来实现 累加操作

package main

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

/**
    互斥量的概念!go语言提供的锁:Mutex (sync.Mutex)

    // go 语言提供了原子类型的操作,在 sync/atomic 包下
    // 比如 atomic.AddInt32() 就是累加操作

    累加操作,就算多个协程同时累加,也是安全,优先使用 go 语言提供的!


    在这里手动实现一个互斥量, 用来实现 累加操作

*/

/**
由于 会出现我在写的时候,另一个人却在读,导致冲突, 所以进行改写
 */
// 声明一个 int 类型
// type atomicInt int

// 获取值
//func (a *atomicInt) get() int {
//  // 返回值,包装一下,就不会返回地址
//  return int(a)
//}

/**
    改写后
 */

type atomicInt struct {
    value int
    lock sync.Mutex // 互斥锁, 也就是我正在操作的时候,我排斥其他人操作
}

// 加一 操作
func (a *atomicInt) increment() {
    // 在写的时候,进行上锁保护, 防止读写冲突
    a.lock.Lock()
    // 释放锁, 执行完毕后我就释放锁
    defer a.lock.Unlock()
    a.value ++

}

// 获取值
func (a *atomicInt) get() int {
    // 返回值,包装一下,就不会返回地址
    // 上锁
    a.lock.Lock()
    // 释放锁, 读完后我释放锁
    defer a.lock.Unlock()
    return a.value
}

func main() {
    var a atomicInt
    a.increment()
    go func() {
        a.increment()
    }()

    /**
        这个时候会有一个问题,就是我 a 正在写的时候,另一个却正在读这个 a,导致冲突!
        改写后就解决了这个问题!
     */

    time.Sleep(time.Millisecond)
    fmt.Println(a.get())


}


有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:爱吃豆包

查看原文:golang-互斥锁

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

937 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传