سلامة السباقات والمزامنة

package main

import (
	"fmt"
	"sync"
)

func main() {
	counts := map[string]int{"jobs": 0}
	var mu sync.Mutex
	var workers sync.WaitGroup
	workers.Add(2)
	for worker := 0; worker < 2; worker++ {
		go func() {
			defer workers.Done()
			for i := 0; i < 1000; i++ {
				mu.Lock()
				counts["jobs"]++
				mu.Unlock()
			}
		}()
	}
	workers.Wait()
	mu.Lock()
	result := counts["jobs"]
	mu.Unlock()
	fmt.Println("jobs", result)
}

jobs 2000

تُحمى كل زيادة كاملة ويثبت Wait اكتمال التحديثات الألفين.

package main

import (
	"fmt"
	"sync"
	"sync/atomic"
)

func main() {
	var count atomic.Int64
	var workers sync.WaitGroup
	workers.Add(2)
	for worker := 0; worker < 2; worker++ {
		go func() {
			defer workers.Done()
			for i := 0; i < 1000; i++ {
				count.Add(1)
			}
		}()
	}
	workers.Wait()
	fmt.Println("count", count.Load())
}

count 2000

كل Add تحديث ذري واحد فتحتوي النتيجة بعد الانتظار ألف زيادة من كل حلقة.