Searched refs:nThreads (Results 1 – 8 of 8) sorted by relevance
26 int nThreads = 1; field in ConcurrentModificationExceptionOnMultiThreadedVerificationTest37 fixedThreadPool = Executors.newFixedThreadPool(nThreads); in setUp()48 verify(target, timeout(expectedMaxTestLength).times(TIMES * nThreads)).targetMethod("arg"); in shouldSuccessfullyVerifyConcurrentInvocationsWithTimeout()55 for(int i=0; i<nThreads; i++) { in startInvocations()
70 context.nThreads = n // context.n77 for i in range(context.nThreads)]90 if nFinished == context.nThreads:
66 int nThreads = 20; in testAddAndRemove() local68 int nTasks = nThreads * tasksPerThread; in testAddAndRemove()69 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()
560 int nThreads = 100; in testModify_basher() local568 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher()
825 SBarrierProvider(int nThreads) {826 barrier = new CyclicBarrier(nThreads, new Runnable() {