Searched refs:cyclicBarrier (Results 1 – 1 of 1) sorted by relevance
2972 final CyclicBarrier cyclicBarrier = new CyclicBarrier(readerCount + 1); in testConcurrencyReadWrite() local2979 waitForCyclicBarrier(cyclicBarrier); in testConcurrencyReadWrite()2980 cyclicBarrier.reset(); in testConcurrencyReadWrite()3010 waitForCyclicBarrier(cyclicBarrier); in testConcurrencyReadWrite()3087 private void waitForCyclicBarrier(CyclicBarrier cyclicBarrier) { in waitForCyclicBarrier() argument3089 cyclicBarrier.await(LATCH_TIMEOUT_MS, TimeUnit.MILLISECONDS); in waitForCyclicBarrier()