Function TestConcurrentGetOrCreateAndRemoveIf

server/group/registry_test.go:80–102

(t *testing.T)

}

func TestConcurrentGetOrCreateAndRemoveIf(t *testing.T) {
	r := newGroupRegistry[*int]()
	const n = 100
	var wg sync.WaitGroup
	wg.Add(n * 2)
	for i := range n {
		v := i
		go func() {
			defer wg.Done()
			r.getOrCreate("k", func() *int { return &v })
		}()
		go func() {
			defer wg.Done()
			r.removeIf("k", func(*int) bool { return true })
		}()
	}
	wg.Wait()

	// After all goroutines finish, accessing the key must not panic.
	require.NotPanics(t, func() {
		_, _ = r.get("k")
	})
}