Function TestAtomicMap_MultipleThreads

pkg/atomic_map/atomic_map_test.go:117–139

(t *testing.T)

}

func TestAtomicMap_MultipleThreads(t *testing.T) {
	atomicMap := NewAtomicMap[string, int]()

	var wg sync.WaitGroup

	size := 1000
	wg.Add(size)

	for i := 0; i < size; i++ {
		go func(idx int) {
			key := fmt.Sprintf("key:%d", idx)
			atomicMap.Set(key, 0)
			atomicMap.RemoveKey(key)
			atomicMap.Set(key, 0xbeef)
			wg.Done()
		}(i)
	}

	wg.Wait()

	keys := atomicMap.Keys()
	assert.Lenf(t, keys, size, "Map should have %d keys", size)
}