Home
last modified time | relevance | path

Searched refs:threadPool (Results 1 – 25 of 27) sorted by relevance

12

/external/guava/guava-tests/test/com/google/common/collect/
DQueuesTest.java71 private ExecutorService threadPool; field in QueuesTest
75 threadPool = newCachedThreadPool(); in setUp()
80 threadPool.shutdown(); in tearDown()
81 assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); in tearDown()
106 Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
108 Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
110 Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
112 Future<?> possiblyIgnoredError3 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
114 Future<?> possiblyIgnoredError4 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
136 Future<?> producerThread = threadPool.submit(producer); in testDrainTimesOut()
[all …]
/external/guava/android/guava-tests/test/com/google/common/collect/
DQueuesTest.java71 private ExecutorService threadPool; field in QueuesTest
75 threadPool = newCachedThreadPool(); in setUp()
80 threadPool.shutdown(); in tearDown()
81 assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); in tearDown()
106 Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
108 Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
110 Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
112 Future<?> possiblyIgnoredError3 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
114 Future<?> possiblyIgnoredError4 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
136 Future<?> producerThread = threadPool.submit(producer); in testDrainTimesOut()
[all …]
/external/tink/java_src/src/test/java/com/google/crypto/tink/internal/
DMutableSerializationRegistryMultithreadTest.java218 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndParseAndSerializeInParallel_works() local
242 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
257 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
290 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
301 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
314 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
329 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
363 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
374 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
386 threadPool.shutdown(); in registerAndParseAndSerializeInParallel_works()
[all …]
DMutablePrimitiveRegistryMultithreadTest.java112 ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_NUMBER); in registerAndGetPrimitivesInParallel_works() local
124 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
137 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
157 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
170 threadPool.shutdown(); in registerAndGetPrimitivesInParallel_works()
171 assertThat(threadPool.awaitTermination(300, SECONDS)).isTrue(); in registerAndGetPrimitivesInParallel_works()
/external/tink-java/src/test/java/com/google/crypto/tink/internal/
DMutableSerializationRegistryMultithreadTest.java218 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndParseAndSerializeInParallel_works() local
242 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
257 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
290 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
301 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
314 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
329 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
363 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
374 threadPool.submit( in registerAndParseAndSerializeInParallel_works()
386 threadPool.shutdown(); in registerAndParseAndSerializeInParallel_works()
[all …]
DMutablePrimitiveRegistryMultithreadTest.java112 ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_NUMBER); in registerAndGetPrimitivesInParallel_works() local
124 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
137 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
157 threadPool.submit( in registerAndGetPrimitivesInParallel_works()
170 threadPool.shutdown(); in registerAndGetPrimitivesInParallel_works()
171 assertThat(threadPool.awaitTermination(300, SECONDS)).isTrue(); in registerAndGetPrimitivesInParallel_works()
/external/tink-java/src/test/java/com/google/crypto/tink/
DRegistryMultithreadTest.java70 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndGetKeyManager_works() local
74 threadPool.submit( in registerAndGetKeyManager_works()
85 threadPool.submit( in registerAndGetKeyManager_works()
96 threadPool.shutdown(); in registerAndGetKeyManager_works()
98 assertThat(threadPool.awaitTermination(1, DAYS)).isTrue(); in registerAndGetKeyManager_works()
/external/tink/java_src/src/test/java/com/google/crypto/tink/
DRegistryMultithreadTest.java181 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndGetKeyManager_works() local
190 threadPool.submit( in registerAndGetKeyManager_works()
201 threadPool.submit( in registerAndGetKeyManager_works()
212 threadPool.submit( in registerAndGetKeyManager_works()
226 threadPool.submit( in registerAndGetKeyManager_works()
240 threadPool.shutdown(); in registerAndGetKeyManager_works()
241 assertThat(threadPool.awaitTermination(300, SECONDS)).isTrue(); in registerAndGetKeyManager_works()
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/
DPingPongWithBlockingContext.kt28 private val threadPool = newFixedThreadPoolContext(8, "PongCtx") constant in benchmarks.scheduler.actors.PingPongWithBlockingContext
32 threadPool.close() in tearDown()
44 runPingPongs(experimental, threadPool) in withContextPingPong()
49 runPingPongs(ForkJoinPool.commonPool().asCoroutineDispatcher(), threadPool) in commonPoolWithContextPingPong()
/external/apache-commons-lang/src/test/java/org/apache/commons/lang3/builder/
DToStringStyleConcurrencyTest.java90 final ExecutorService threadPool = Executors.newFixedThreadPool(2); in testConcurrency() local
103 final List<Future<Integer>> futures = threadPool.invokeAll(tasks); in testConcurrency()
106 threadPool.shutdown(); in testConcurrency()
107 threadPool.awaitTermination(1, TimeUnit.SECONDS); in testConcurrency()
DReflectionToStringBuilderConcurrencyTest.java91 final ExecutorService threadPool = Executors.newFixedThreadPool(2); in testConcurrency() local
111 final List<Future<Integer>> futures = threadPool.invokeAll(tasks); in testConcurrency()
114 threadPool.shutdown(); in testConcurrency()
115 threadPool.awaitTermination(1, TimeUnit.SECONDS); in testConcurrency()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAtomicLongMapBasherTest.java50 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
54 threadPool.submit( in testModify_basher()
115 threadPool.shutdown(); in testModify_basher()
116 assertTrue(threadPool.awaitTermination(300, SECONDS)); in testModify_basher()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAtomicLongMapBasherTest.java50 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
54 threadPool.submit( in testModify_basher()
115 threadPool.shutdown(); in testModify_basher()
116 assertTrue(threadPool.awaitTermination(300, SECONDS)); in testModify_basher()
/external/zstd/programs/
Dfileio_asyncio.c165 ctx->threadPool = NULL; in AIO_IOPool_createThreadPool()
173 ctx->threadPool = POOL_create(1, MAX_IO_JOBS - 2); in AIO_IOPool_createThreadPool()
175 if (!ctx->threadPool) in AIO_IOPool_createThreadPool()
187 ctx->totalIoJobs = ctx->threadPool ? MAX_IO_JOBS : 2; in AIO_IOPool_init()
201 return ctx->threadPool && ctx->threadPoolActive; in AIO_IOPool_threadPoolActive()
233 POOL_joinJobs(ctx->threadPool); in AIO_IOPool_join()
252 if(ctx->threadPool) { in AIO_IOPool_destroy()
257 POOL_free(ctx->threadPool); in AIO_IOPool_destroy()
304 POOL_add(ctx->threadPool, ctx->poolFunction, job); in AIO_IOPool_enqueueJob()
471 assert(ctx->base.threadPool != NULL); /* we shouldn't be here if we work in sync mode */ in AIO_ReadPool_getNextCompletedJob()
[all …]
Dfileio_asyncio.h36 POOL_ctx* threadPool; member
/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
DCrtMemoryLeakDetector.java153 final ExecutorService threadPool = Executors.newFixedThreadPool(32); in determineBaselineGrowth()
159 threadPool.execute(() -> { in determineBaselineGrowth()
190 final ExecutorService threadPool = Executors.newFixedThreadPool(numThreads); in runViaThreadPool() local
196 threadPool.execute(() -> { in runViaThreadPool()
DHttp2StreamManagerTest.java88 final ExecutorService threadPool = Executors.newFixedThreadPool(numThreads); in testParallelStreams() local
97 threadPool.execute(() -> { in testParallelStreams()
/external/zstd/lib/common/
Dpool.c223 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customCalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal() local
224 if (!threadPool) return 1; in POOL_resize_internal()
226 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(ZSTD_pthread_t)); in POOL_resize_internal()
228 ctx->threads = threadPool; in POOL_resize_internal()
232 if (ZSTD_pthread_create(&threadPool[threadId], NULL, &POOL_thread, ctx)) { in POOL_resize_internal()
/external/guava/guava-tests/test/com/google/common/cache/
DCacheBuilderTest.java496 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
502 threadPool.submit( in testRemovalNotification_clear_basher()
544 threadPool.shutdown(); in testRemovalNotification_clear_basher()
545 threadPool.awaitTermination(300, SECONDS); in testRemovalNotification_clear_basher()
596 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
600 threadPool.submit( in testRemovalNotification_get_basher()
614 threadPool.shutdown(); in testRemovalNotification_get_basher()
615 threadPool.awaitTermination(300, SECONDS); in testRemovalNotification_get_basher()
/external/guava/android/guava-tests/test/com/google/common/cache/
DCacheBuilderTest.java505 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
511 threadPool.submit( in testRemovalNotification_clear_basher()
553 threadPool.shutdown(); in testRemovalNotification_clear_basher()
554 threadPool.awaitTermination(300, SECONDS); in testRemovalNotification_clear_basher()
605 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
609 threadPool.submit( in testRemovalNotification_get_basher()
623 threadPool.shutdown(); in testRemovalNotification_get_basher()
624 threadPool.awaitTermination(300, SECONDS); in testRemovalNotification_get_basher()
/external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/
DMultithreadingTest.kt26 newSingleThreadContext("testSingleThread").use { threadPool -> in <lambda>() method
31 Dispatchers.setMain(threadPool) in <lambda>()
/external/skia/tests/
DGrContextFactoryTest.cpp92 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1); in DEF_GANESH_TEST() local
93 contextOptions.fExecutor = threadPool.get(); in DEF_GANESH_TEST()
/external/angle/src/image_util/
DAstcDecompressor.cpp215 std::shared_ptr<WorkerThreadPool> &threadPool = in decompress() local
226 mWaitEvents.push_back(threadPool->postWorkerTask(mTasks[i])); in decompress()
/external/guava/android/guava-tests/benchmark/com/google/common/collect/
DConcurrentHashMultisetBenchmark.java58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
68 threadPool = in setUp()
99 futures.add(threadPool.submit(task));
/external/guava/guava-tests/benchmark/com/google/common/collect/
DConcurrentHashMultisetBenchmark.java58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
68 threadPool = in setUp()
99 futures.add(threadPool.submit(task));

12