diff --git a/vlib/sync/waitgroup_test.v b/vlib/sync/waitgroup_test.v index 6afed8cf3c..8342bb25f1 100644 --- a/vlib/sync/waitgroup_test.v +++ b/vlib/sync/waitgroup_test.v @@ -1,6 +1,7 @@ module sync import time +import sync.stdatomic fn test_waitgroup_reuse() { mut wg := new_waitgroup() @@ -41,14 +42,13 @@ fn test_waitgroup_no_use() { } fn test_waitgroup_go() { - mut counter := 0 - p := unsafe { &counter } + mut counter := stdatomic.new_atomic(0) mut wg := new_waitgroup() for i in 0 .. 10 { - wg.go(fn [p] () { - unsafe { (*p)++ } + wg.go(fn [mut counter] () { + counter.add(1) }) } wg.wait() - assert counter == 10 + assert counter.load() == 10 }