Function TestOpenFilePool_Concurrent

internal/caches/open_file_pool_test.go:28–46

(t *testing.T)

}

func TestOpenFilePool_Concurrent(t *testing.T) {
	var pool = caches.NewOpenFilePool("a")
	var concurrent = 1000
	var wg = &sync.WaitGroup{}
	wg.Add(concurrent)
	for i := 0; i < concurrent; i++ {
		go func() {
			defer wg.Done()

			if rands.Int(0, 1) == 1 {
				pool.Put(caches.NewOpenFile(nil, nil, nil, 0, 1))
			}
			if rands.Int(0, 1) == 0 {
				pool.Get()
			}
		}()
	}
	wg.Wait()
}