| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| ConcurrentModificationExceptionOnMultiThreadedVerificationTest.java | 26 int nThreads = 1;
37 fixedThreadPool = Executors.newFixedThreadPool(nThreads);
48 verify(target, timeout(expectedMaxTestLength).times(TIMES * nThreads)).targetMethod("arg");
55 for(int i=0; i<nThreads; i++) {
|
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| AsynchronousChannelGroup.java | 159 * threads. At any point, at most {@code nThreads} threads will be active
169 * @param nThreads
177 * If {@code nThreads <= 0}
181 public static AsynchronousChannelGroup withFixedThreadPool(int nThreads,
186 .openAsynchronousChannelGroup(nThreads, threadFactory);
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 126 static ThreadPool create(int nThreads, ThreadFactory factory) {
127 if (nThreads <= 0)
128 throw new IllegalArgumentException("'nThreads' must be > 0");
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory);
130 return new ThreadPool(executor, true, nThreads);
|
| LinuxAsynchronousChannelProvider.java | 54 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory)
57 return new EPollPort(this, ThreadPool.create(nThreads, factory)).start();
|
| EPollPort.java | 159 int nThreads = threadCount();
160 if (nThreads == 0) {
164 while (nThreads-- > 0) {
|
| /frameworks/base/core/java/com/android/internal/util/ |
| ConcurrentUtils.java | 45 * @param nThreads the number of threads in the pool
50 public static ExecutorService newFixedThreadPool(int nThreads, String poolName,
52 return Executors.newFixedThreadPool(nThreads,
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_capi.py | 61 context.nThreads = n // context.n
66 for i in range(context.nThreads):
85 if nFinished == context.nThreads:
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ConcurrentHashMultisetBasherTest.java | 66 int nThreads = 20;
68 int nTasks = nThreads * tasksPerThread;
69 ExecutorService pool = Executors.newFixedThreadPool(nThreads);
|
| MapMakerTest.java | 125 int nThreads = 100;
138 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
154 while (computedCount.get() < nThreads) {
|
| /external/python/cpython2/Lib/test/ |
| test_capi.py | 70 context.nThreads = n // context.n
77 for i in range(context.nThreads)]
90 if nFinished == context.nThreads:
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_capi.py | 63 context.nThreads = n // context.n
68 for i in range(context.nThreads):
87 if nFinished == context.nThreads:
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_capi.py | 63 context.nThreads = n // context.n
68 for i in range(context.nThreads):
87 if nFinished == context.nThreads:
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_capi.py | 63 context.nThreads = n // context.n
68 for i in range(context.nThreads):
87 if nFinished == context.nThreads:
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_capi.py | 63 context.nThreads = n // context.n
68 for i in range(context.nThreads):
87 if nFinished == context.nThreads:
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| Executors.java | 83 * {@code nThreads} threads will be active processing tasks.
91 * @param nThreads the number of threads in the pool
93 * @throws IllegalArgumentException if {@code nThreads <= 0}
95 public static ExecutorService newFixedThreadPool(int nThreads) {
96 return new ThreadPoolExecutor(nThreads, nThreads,
143 * at most {@code nThreads} threads will be active processing
152 * @param nThreads the number of threads in the pool
156 * @throws IllegalArgumentException if {@code nThreads <= 0}
158 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory)
[all...] |
| /frameworks/wilhelm/src/ |
| ThreadPool.cpp | 81 static void ThreadPool_deinit_internal(ThreadPool *tp, unsigned initialized, unsigned nThreads);
93 unsigned nThreads = 0; // number of threads successfully created
154 ++nThreads;
163 ThreadPool_deinit_internal(tp, initialized, nThreads);
167 static void ThreadPool_deinit_internal(ThreadPool *tp, unsigned initialized, unsigned nThreads)
173 if (0 < nThreads) {
185 for (i = 0; i < nThreads; ++i) {
|
| /libcore/ojluni/src/main/java/java/nio/channels/spi/ |
| AsynchronousChannelProvider.java | 172 * @param nThreads
180 * If {@code nThreads <= 0}
187 openAsynchronousChannelGroup(int nThreads, ThreadFactory threadFactory) throws IOException;
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| CacheBuilderTest.java | 462 int nThreads = 100;
476 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
492 while (computedCount.get() < nThreads) {
528 int nThreads = 100;
565 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
|
| CacheLoadingTest.java | [all...] |
| /external/python/cpython3/Lib/test/ |
| test_capi.py | 291 context.nThreads = n // context.n
298 for i in range(context.nThreads)]
311 if nFinished == context.nThreads:
|
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.6.Final/ |
| netty-transport-4.1.6.Final.jar | |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AtomicLongMapTest.java | 560 int nThreads = 100;
568 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
|
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.3.Final/ |
| netty-transport-4.1.3.Final.jar | |
| /external/guice/core/test/com/google/inject/ |
| ScopesTest.java | 818 * nThreads}. Intended to be used for threads synchronization during injection.
825 SBarrierProvider(int nThreads) {
826 barrier = new CyclicBarrier(nThreads, new Runnable() {
[all...] |
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.0.CR3/ |
| netty-transport-4.1.0.CR3.jar | |
