Function BenchmarkParallelCacheGetBatched

cache_test.go:1113–1138

(b *testing.B)

)

func BenchmarkParallelCacheGetBatched(b *testing.B) {
	b.ReportAllocs()
	b.StopTimer()
	cache := NewCache(256 * 1024 * 1024)
	buf := make([]byte, 64)
	var key [8]byte
	for i := 0; i < benchDataSize; i++ {
		binary.LittleEndian.PutUint64(key[:], uint64(i))
		cache.Set(key[:], buf, 0)
	}
	b.StartTimer()
	b.RunParallel(func(pb *testing.PB) {
		keys := make([][]byte, benchBatchSize)
		for i := range keys {
			keys[i] = make([]byte, 8)
		}
		i := 0
		for pb.Next() {
			for j := 0; j < benchBatchSize; j++ {
				binary.LittleEndian.PutUint64(key[:], uint64((i+j)%benchDataSize))
				cache.Get(key[:])
			}
			i++
		}
	})
}

func BenchmarkParallelCacheMultiGetBatched(b *testing.B) {
	b.ReportAllocs()