Function TestCache_ConcurrentAccess

test/cache_test.go:130–155

(t *testing.T)

}

func TestCache_ConcurrentAccess(t *testing.T) {
	cache := createTestCache(t)
	key := "concurrent-key"

	t.Run("concurrent set and get", func(t *testing.T) {
		const goroutines = 10
		done := make(chan bool, goroutines)

		for i := 0; i < goroutines; i++ {
			go func(idx int) {
				defer func() { done <- true }()

				value := string(rune('A' + idx))
				cache.Set(key, value, time.Minute)

				got, ok := cache.Get(key)
				assert.True(t, ok)
				assert.NotEmpty(t, got)
			}(i)
		}

		for i := 0; i < goroutines; i++ {
			<-done
		}
	})
}

func createTestCache(t *testing.T) *cache.Cache[string, string] {
	t.Helper()