Go中的同步与锁

栏目: Go · 发布时间: 6年前

内容简介:Go中的同步与锁

最近学习了 Go 语言中同步包中的互斥锁、读写锁、Once、waitGroup。在并发程序开发的过程中,这两种锁是非常重要的,包括对共享资源进行访问控制的时候。sync是Go语言中的标准库。

Mutex 互斥锁

  • 互斥锁是传统并发程序对共享资源进行访问控制的主要手段。是sync包中的Mutex结构体。
    • type Mutex struct {}
  • 该结构体包括了两个方法,可以说是非常简单使用的
    • func (m *Mutex) Lock() {}
    • func (m *Mutex) Unlock() {}
  • 我们通过一个简单的例子来说明他的用法:
package main

import (
	"sync"
	"fmt"
)

type safeCounter struct {
	number int
	sync.Mutex
}

func (sc *safeCounter)Increment() {
	sc.Lock()
	sc.number++
	sc.Unlock()
}

func (sc *safeCounter)Decrement() {
	sc.Lock()
	sc.number--
	sc.Unlock()
}

func (sc *safeCounter)getNumber()int {
	sc.Lock()
	number := sc.number
	sc.Unlock()
	return number
}

func main() {
	sc := new(safeCounter)
	for i := 0; i < 100; i++ {
		go sc.Increment()
		go sc.Decrement()
	}
	fmt.Println(sc.getNumber())
}
  • 上述例子通过互斥锁来保证number整型变量在使用goroutine的情况下,持续稳定地输出0的结果。当然你可以试一下,去掉锁的保护,是否还可以稳定输出0?

RWMutex 读写锁

  • 读写锁是针对读写操作的互斥锁。遵循两个原则即可

    • 可以随便地读,并且支持多个goroutine同时读取
    • 写的时候,既不能读也不能写。
  • RWMutex 提供了四个方法

    • func (*RWMutex) Lock

    • func (*RWMutex) Unlock

    • func (*RWMutex) RLock

    • func (*RWMutex) RUnlock

  • 通过读写map的一个例子来说明RWMutex的使用方法:

package main

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

type MapCounter struct {
	m map[int]int
	sync.RWMutex
}

func (mapCounter *MapCounter)Reader(nint) {
	for {
		mapCounter.RLock()
		v := mapCounter.m[rand.Intn(n)]
		mapCounter.RUnlock()
		fmt.Println(v)
		time.Sleep(1 * time.Second)
	}
}

func (mapCounter *MapCounter)Writer(nint) {
	for i := 0; i < n; i++ {
		mapCounter.Lock()
		mapCounter.m[i] = i * 10
		mapCounter.Unlock()
		time.Sleep(1 * time.Second)
	}
}

func main() {
	mc := MapCounter{m: make(map[int]int)}
	go mc.Writer(10)
	go mc.Reader(10)
	go mc.Reader(10)
	time.Sleep(15 * time.Second)
}

Once

  • Once 顾名思义,就是只执行一次 。通过一个简单的例子就可以说明:
package main

import (
	"fmt"
	"sync"
)

func main() {
	once := sync.Once{}
	done := make(chan bool)

	for i := 0; i < 10; i++ {
		go func() {
			once.Do(sayHello)
			done <- true
		}()
	}

	for i := 0; i < 10; i++ {
		fmt.Println(<-done)
	}
}

func sayHello() {
	fmt.Println("Hello")
}
  • 以上的例子只输出了一个“Hello” ,其余的都是true。

WaitGroup

  • WaitGroup 是可以一个goroutine集合,当集合里的goroutine执行完毕后,这个WaitGroup就会自动结束。你可以定义这个WaitGroup的大小。他里面只有三个方法:
    • func (wg *WaitGroup) Add(delta int) {} //定义大小
    • func (wg *WaitGroup) Done() {}
    • func (wg *WaitGroup) Wait() {}
  • 具体用法,通过下面的小例子说明。
package main

import (
	"fmt"
	"sync"
)

func main() {
	wg := sync.WaitGroup{}
	for i := 0; i <= 5; i++ {
		wg.Add(1)
		go func(iint) {

			defer wg.Done()

			fmt.Println("Work done for ", i)

		}(i)
	}

	wg.Wait()
}
  • 建议大家可以把上面的代码都跑一遍,方便自己理解代码的含义。结合官方文档来理解会更加容易。

以上所述就是小编给大家介绍的《Go中的同步与锁》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

程序与法治

程序与法治

孙洪坤 / 中国检察 / 2008-3 / 28.00元

《程序与法治》是系统和全面地研究程序与法治国家建设思想的学术专著,《程序与法治》对程序与法治的若干重大理论与现实问题进行了深入的探讨,如:从法社会学的视角研究程序正义在中国的可适应性问题;程序正义的中国语境;正当程序的宪政价值与构造;正当程序的文化底蕴;中国刑事程序正当化设计的标准、设计的基调、设计的视角;等等。尽管其中某些问题的研究尚待进一步深入,但这些问题的提出有利于开阔我们研究程序法理论的视......一起来看看 《程序与法治》 这本书的介绍吧!

html转js在线工具
html转js在线工具

html转js在线工具

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试