konkurentnost-v-go-gonk_atomic.go

package main

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

type atomicCounter struct {
	val int64
}

func (c *atomicCounter) Add(x int64) {
	atomic.AddInt64(&c.val, x)
	runtime.Gosched()
}

func (c *atomicCounter) Value() int64 {
	return atomic.LoadInt64(&c.val)
}

func main() {
	counter := atomicCounter{}

	counter = process(counter)

	// time.Sleep(time.Second)
	fmt.Println(counter.Value())
}

func process(counter atomicCounter) atomicCounter {
	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
}