go_routine_race_conditions_ex.go

package main

import (
        "fmt"
        "sync"
)

var wg sync.WaitGroup

type Processor struct {
    mu sync.Mutex
    sum int
}

func (p *Processor) process(n string) {
        wg.Add(1)
        go func() {
                defer wg.Done()

                for i := 0; i < 10000; i++ {
                        p.mu.Lock()
                        p.sum = p.sum + 1
                        p.mu.Unlock()
                }

                fmt.Println("From " + n + ":", p.sum)
        }()
}

func main() {
        processes := []string{"A", "B", "C", "D", "E"}
		processor := &Processor{mu: sync.Mutex{}, sum: 0}
        for _, p := range processes {
                processor.process(p)
        }

        wg.Wait()
        fmt.Println("Final Sum:", processor.sum)
}