go语言goroutine并发安全和锁（五）

package main
/*
golang并发安全和锁

互斥锁：并发编程中对共享资源进行访问的控制手段，由标准库中的Mutex结构体类型，
       sync.Mutex类型只有两个公开的指针方法，Lock和Unlock

       可以通过go build -race  main.go 编译后运行， 查看共享资源的竞争

       互斥锁本质是当一个goroutine访问的时候，其他的goroutin都不能访问，
       程序由原来的并行执行变成了串行执行
 读写锁：读写锁可以让多个读操作并发，同时读取，但是对于写操作是完全互斥的。
        当一个goroutine进行写操作的时候，其他的goroutine不能读也不能写
*/


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

var count=0
var wg sync.WaitGroup

var mutex sync.Mutex
/*
对共享资源的访问不加锁的输出结果如下：会出现两个协程同时操作共享资源的情况
count is: 1
count is: 2
count is: 5
count is: 6
count is: 3
count is: 5
count is: 7
count is: 8
count is: 11
count is: 11
count is: 9
count is: 13
count is: 14
count is: 12
count is: 15
count is: 16
count is: 17
count is: 18
count is: 20
count is: 19

加锁后输出的结果如下：
count is: 1
count is: 2
count is: 3
count is: 4
count is: 5
count is: 6
count is: 7
count is: 8
count is: 9
count is: 10
count is: 11
count is: 12
count is: 13
count is: 14
count is: 15
count is: 16
count is: 17
count is: 18
count is: 19
count is: 20
*/

//互斥锁
func test(){
	mutex.Lock()
	count++
	fmt.Println("count is:",count)
	time.Sleep(time.Millisecond)
	mutex.Unlock()

	wg.Done()
}

//读写互斥锁，读的时候并行执行，写的时候串行执行,当一个goroutine执行写的时候不能读和写，执行读的时候，其他goroutine也可以读
var mutex1 sync.RWMutex

func write(){
	mutex1.Lock()
	fmt.Println("---write")
	time.Sleep(time.Millisecond*10)
	mutex1.Unlock()
	wg.Done()
}

func read(){
	mutex1.RLock()
	fmt.Println("read")
	time.Sleep(time.Millisecond*10)
	mutex1.RUnlock()
	wg.Done()
}


func main() {
	for r:=0;r<20;r++{
		wg.Add(1)
		go test()
	}

	for i:=0;i<10;i++{
		wg.Add(1)
		go write()
	}

	for i:=0;i<10;i++{
		wg.Add(1)
		go read()
	}

	wg.Wait()
}