Function benchRistrettoGetHitParallel

resolver/ristretto_metrics_bench_test.go:94–121

(b *testing.B, metrics bool)

}

func benchRistrettoGetHitParallel(b *testing.B, metrics bool) {
	c := newBenchCache(b, metrics)
	defer c.Close()

	const entries = 1 << 16
	val := make([]byte, 256)
	for i := range entries {
		c.Set(uint64(i), val, int64(len(val)))
	}
	c.Wait()

	b.ReportAllocs()
	b.ResetTimer()

	b.RunParallel(func(pb *testing.PB) {
		// Give each worker a distinct offset so they don't all hammer the same key.
		// strconv is a cheap way to get some per-goroutine entropy here.
		var off uint64
		if s := strconv.Itoa(int(b.N)); len(s) > 0 {
			off = uint64(s[0])
		}
		var i uint64
		for pb.Next() {
			_, _ = c.Get((i + off) & (entries - 1))
			i++
		}
	})
}