package main
// 互斥锁 Mutex(sync.Mutex)
import (
"fmt"
"sync"
)
var (
G_num int = 0
wg sync.WaitGroup // 定义一个全局变量的 wg 计数器对象
lock sync.Mutex // 定义一个全局变量的 lock 互斥锁对象
)
func sum(){
defer wg.Done() // 延迟调用, wg 计数器对象 ——1
for i := 0; i < 1000000; i++ {
lock.Lock()
G_num += 1
lock.Unlock()
}
}
func main() {
wg.Add(1)
go sum()
wg.Add(1)
go sum()
wg.Wait() // 在此阻塞,等待所有的子线程都执行完毕,再结束程序的主线程
fmt.Println(G_num)
}
有疑问加站长微信联系(非本文作者)