Function TestConcurrentCountMap_ConcurrentIncrement

internal/stats/count_map_test.go:126–155

(t *testing.T)

}

func TestConcurrentCountMap_ConcurrentIncrement(t *testing.T) {
	const (
		key         = 7
		concurrency = 8
		inc         = 1000
	)

	var m CountersMap[int]

	var wg sync.WaitGroup

	wg.Add(concurrency)

	for range concurrency {
		go func() {
			for range inc {
				m.Increment(key)
			}

			wg.Done()
		}()
	}

	wg.Wait()

	got, found := m.Get(key)

	require.True(t, found)
	require.EqualValues(t, concurrency*inc, got)
}