Function BenchmarkLockFreePoolGetPut2Thread

server/libs/pool/pool_test.go:105–127

(b *testing.B)

}

func BenchmarkLockFreePoolGetPut2Thread(b *testing.B) {
	pools := make([]*LockFreePool[int], 16)
	for i := range pools {
		pool := NewLockFreePool(func() int { return 0 })
		pools[i] = pool
	}

	put := func(pool []*LockFreePool[int]) {
		for i := 0; i < b.N; i++ {
			for _, p := range pools {
				p.Put(0)
			}
		}
	}

	b.ResetTimer()
	go put(pools)
	for i := 0; i < b.N; i++ {
		for _, p := range pools {
			p.Get()
		}
	}
}

func BenchmarkLockFreePoolHungryGet(b *testing.B) {
	pool := NewLockFreePool[int](func() int { return 0 })