module main

import x.atomics

fn increment(counter &i64) {
	atomics.add_i64(counter, 1)
}

fn worker(counter &i64, iterations int) {
	for _ in 0 .. iterations {
		increment(counter)
	}
}

fn main() {
	mut counter := i64(0)

	num_threads := 4
	increments_per_thread := 10000

	mut threads := []thread{}

	for _ in 0 .. num_threads {
		threads << spawn worker(&counter, increments_per_thread)
	}

	threads.wait()

	expected := i64(num_threads * increments_per_thread)
	actual := atomics.load_i64(&counter)

	println('Expected: ${expected}')
	println('Actual:   ${actual}')

	if actual == expected {
		println('Counter is correct')
	} else {
		println('Counter mismatch - race condition detected')
	}
}