go语言实现一个简单的原子互斥操作
package main
import (
"fmt"
"sync"
)
var total struct { //指定一个结构体声明一个sync.Mutex类型.
sync.Mutex
value int
}
func worker(wg *sync.WaitGroup) { //这里需要输入一个指针类型,如果输入的是值类型的话会报错,报错信息是死锁
defer wg.Done() //程序结束事减少一个goroutine的,这是一个计数器.一般都应用在方法函数中.
for i := 1; i <= 100; i++ {
total.Lock()
total.value += i
total.Unlock()
}
}
func main() {
var wg sync.WaitGroup
wg.Add(2) //指定启动goroutin的数量.这里启动了两个那么就在wg.add方法中添加数量2.会在调用函数的时候逐一进行释放操作.直到最后计数为0.
go worker(&wg)//这里需要输入一个指针类型,如果输入的是值类型的话会报错,报错信息是死锁.
go worker(&wg)
wg.Wait()
fmt.Println(total.value)
}