Function BenchmarkLoadingCacheCapped_MultiThread

cache_test.go:89–118

(b *testing.B)

}

func BenchmarkLoadingCacheCapped_MultiThread(b *testing.B) {
	rand.Seed(benchLoadingCacheRandSeed)
	c := NewLoadingCache(
		func(key interface{}) (interface{}, error) {
			return key, nil
		}, benchLoadingCacheCap)
	errCh := make(chan error, benchLoadingCacheConcurrency)
	defer close(errCh)
	for i := 0; i < benchLoadingCacheConcurrency; i++ {
		go func() {
			for j := 0; j < b.N; j++ {
				k := rand.Intn(benchLoadingCacheKeyRange)
				v, _ := c.get(k)
				if k != v {
					errCh <- fmt.Errorf("key:%q != value:%q", k, v)
					return
				}
			}
			errCh <- nil
			return
		}()
	}
	for i := 0; i < benchLoadingCacheConcurrency; i++ {
		if err := <-errCh; err != nil {
			b.Fatal(err)
		}
	}

	b.Logf("N=%d, concurrency=%d, reset=%d", b.N, benchLoadingCacheConcurrency, c.reset)
}

func BenchmarkLoadingCacheNoCap_SingleThread(b *testing.B) {
	rand.Seed(benchLoadingCacheRandSeed)