Searched refs:nThreads (Results 1 – 8 of 8) sorted by relevance
110 template<typename Tdata, class Tfunc, Ncv32u nThreads>115 __shared__ Tdata _reduceArr[nThreads]; in subReduce()120 if (nThreads >= 256 && threadIdx.x < 128) in subReduce()126 if (nThreads >= 128 && threadIdx.x < 64) in subReduce()134 if (nThreads >= 64) in subReduce()138 if (nThreads >= 32 && threadIdx.x < 16) in subReduce()
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()
610 int32_t nThreads = threadCount; in TestTimeRoundTrip() local681 TestTimeRoundTripThread **threads = new TestTimeRoundTripThread*[nThreads]; in TestTimeRoundTrip()683 for (i = 0; i < nThreads; i++) { in TestTimeRoundTrip()690 for (i = 0; i < nThreads; i++) { in TestTimeRoundTrip()697 for (i = 0; i < nThreads; i++) { in TestTimeRoundTrip()
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() {