Searched refs:nThreads (Results 1 – 6 of 6) sorted by relevance
61 int nThreads = 20; in testAddAndRemove() local63 int nTasks = nThreads * tasksPerThread; in testAddAndRemove()64 ExecutorService pool = Executors.newFixedThreadPool(nThreads); in testAddAndRemove()
125 int nThreads = 100; in testRemovalNotification_clear_basher() local138 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher()154 while (computedCount.get() < nThreads) { in testRemovalNotification_clear_basher()
462 int nThreads = 100; in testRemovalNotification_clear_basher() local476 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher()492 while (computedCount.get() < nThreads) { in testRemovalNotification_clear_basher()528 int nThreads = 100; in testRemovalNotification_get_basher() local565 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher()
2098 int nThreads, final CountDownLatch gettersStartedSignal) throws InterruptedException { in doConcurrentGet() argument2100 final AtomicReferenceArray<Object> result = new AtomicReferenceArray<Object>(nThreads); in doConcurrentGet()2101 final CountDownLatch gettersComplete = new CountDownLatch(nThreads); in doConcurrentGet()2102 for (int i = 0; i < nThreads; i++) { in doConcurrentGet()2135 List<Object> resultList = Lists.newArrayListWithExpectedSize(nThreads); in doConcurrentGet()2136 for (int i = 0; i < nThreads; i++) { in doConcurrentGet()
610 int32_t nThreads = threadCount; in TestTimeRoundTrip() local687 for (i = 0; i < nThreads; i++) { in TestTimeRoundTrip()706 for (i = 0; i < nThreads; i++) { in TestTimeRoundTrip()
560 int nThreads = 100; in testModify_basher() local568 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher()