Function TestRuntimeCache_Decr

cache/runtime/cache_runtime_test.go:161–187

(t *testing.T)

}

func TestRuntimeCache_Decr(t *testing.T) {
	cache := NewRuntimeCache()
	var wg sync.WaitGroup
	wg.Add(2)

	go func(cache *RuntimeCache) {
		for i := 0; i < 50; i++ {
			cache.Decr(TESTCacheKey)
		}

		wg.Add(-1)
	}(cache)

	go func(cache *RuntimeCache) {
		for i := 0; i < 50; i++ {
			cache.Decr(TESTCacheKey)
		}
		wg.Add(-1)
	}(cache)

	wg.Wait()

	value, e := cache.GetInt(TESTCacheKey)
	test.Nil(t, e)

	test.Equal(t, -100, value)
}

func BenchmarkTestRuntimeCache_Get(b *testing.B) {
	cache := NewRuntimeCache()