Function BenchmarkPoolHighContention

pool_pubsub_bench_test.go:363–378

BenchmarkPoolHighContention tests pool performance under high contention

(b *testing.B)

// BenchmarkPoolHighContention tests pool performance under high contention
func BenchmarkPoolHighContention(b *testing.B) {
	ctx := context.Background()
	client := benchmarkClient(32)
	defer client.Close()

	b.ResetTimer()
	b.ReportAllocs()

	b.RunParallel(func(pb *testing.PB) {
		for pb.Next() {
			// High contention Get/Put operations
			pubsub := client.Subscribe(ctx, "test-channel")
			pubsub.Close()
		}
	})
}