Searched refs:readerCount (Results 1 – 1 of 1) sorted by relevance
3340 int readerCount = 2; in testConcurrencyReadWrite() local3341 ExecutorService es = Executors.newFixedThreadPool(readerCount + 1); in testConcurrencyReadWrite()3344 final CyclicBarrier cyclicBarrier = new CyclicBarrier(readerCount + 1); in testConcurrencyReadWrite()3347 for (int t = 0; t < readerCount; t++) { in testConcurrencyReadWrite()3401 + (readTotalTime.doubleValue() / readerCount / loopSize)); in testConcurrencyReadWrite()3418 int readerCount = 2; in testConcurrencyRead() local3419 ExecutorService es = Executors.newFixedThreadPool(readerCount + 1); in testConcurrencyRead()3423 for (int t = 0; t < readerCount; t++) { in testConcurrencyRead()3457 + (readTotalTime.doubleValue() / readerCount / loopSize)); in testConcurrencyRead()