konkurentnost-v-go-gonki_mutex.go

package main

import (
	"fmt"
	"sync"
)

type mutexCounter struct {
	mu sync.Mutex
	x  int64
}

func (c *mutexCounter) Add(x int64) {
	c.mu.Lock()
	c.x += x
	c.mu.Unlock()
}

func (c *mutexCounter) Value() (x int64) {
	c.mu.Lock()
	x = c.x
	c.mu.Unlock()
	return
}

func main() {
	counter := mutexCounter{}
	counter = process(mutexCounter{})

	fmt.Println(counter.Value())

}


func process(counter mutexCounter) mutexCounter {
	var wg sync.WaitGroup
	for i := 0; i < 3; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for j := 0; j < 2; j++ {
				counter.Add(1)
			}
		}()
	}
	wg.Wait()

	return counter
}