Synchronization mechanism of go (sync.mutex)

One , Concurrent i++ operation

 

type atomicInt struct {
	value int
	lock  sync.Mutex
}

func (a *atomicInt) increment() {
	fmt.Println("safe increment")
	fmt.Println(a.value)
	func() {
		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
	for i:=0;i<100;i++{
		go func() {
			a.increment()
		}()
	}
	time.Sleep(time.Millisecond)
	fmt.Println(a.get())
}