| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 70 private ExecutorService threadPool; field in QueuesTest
74 threadPool = newCachedThreadPool(); in setUp()
79 threadPool.shutdown(); in tearDown()
80 assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); in tearDown()
105 Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
107 Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
109 Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
111 Future<?> possiblyIgnoredError3 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
113 Future<?> possiblyIgnoredError4 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
135 Future<?> producerThread = threadPool.submit(producer); in testDrainTimesOut()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 70 private ExecutorService threadPool; field in QueuesTest
74 threadPool = newCachedThreadPool(); in setUp()
79 threadPool.shutdown(); in tearDown()
80 assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS)); in tearDown()
105 Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
107 Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
109 Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
111 Future<?> possiblyIgnoredError3 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
113 Future<?> possiblyIgnoredError4 = threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
135 Future<?> producerThread = threadPool.submit(producer); in testDrainTimesOut()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | GrpcEnvironment.cs | 59 readonly GrpcThreadPool threadPool; field in Grpc.Core.GrpcEnvironment
305 …threadPool = new GrpcThreadPool(this, GetThreadPoolSizeOrDefault(), GetCompletionQueueCountOrDefau… in GrpcEnvironment()
306 threadPool.Start(); in GrpcEnvironment()
316 return this.threadPool.CompletionQueues;
328 return this.threadPool.IsAlive;
338 … var cqIndex = (int) ((cqPickerCounter.Increment() - 1) % this.threadPool.CompletionQueues.Count); in PickCompletionQueue()
339 return this.threadPool.CompletionQueues.ElementAt(cqIndex); in PickCompletionQueue()
397 await threadPool.StopAsync().ConfigureAwait(false); in ShutdownAsync()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongWithBlockingContext.kt | 34 private val threadPool = newFixedThreadPoolContext(8, "PongCtx") constant in benchmarks.scheduler.actors.PingPongWithBlockingContext
38 threadPool.close() in tearDown()
50 runPingPongs(experimental, threadPool) in withContextPingPong()
55 runPingPongs(ForkJoinPool.commonPool().asCoroutineDispatcher(), threadPool) in commonPoolWithContextPingPong()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AtomicLongMapBasherTest.java | 48 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
52 threadPool.submit( in testModify_basher()
114 threadPool.shutdown(); in testModify_basher()
115 assertTrue(threadPool.awaitTermination(300, TimeUnit.SECONDS)); in testModify_basher()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AtomicLongMapBasherTest.java | 48 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
52 threadPool.submit( in testModify_basher()
114 threadPool.shutdown(); in testModify_basher()
115 assertTrue(threadPool.awaitTermination(300, TimeUnit.SECONDS)); in testModify_basher()
|
| /external/zstd/lib/common/ |
| D | pool.c | 212 …{ ZSTD_pthread_t* const threadPool = (ZSTD_pthread_t*)ZSTD_customMalloc(numThreads * sizeof(ZSTD… in POOL_resize_internal() local
213 if (!threadPool) return 1; in POOL_resize_internal()
215 ZSTD_memcpy(threadPool, ctx->threads, ctx->threadCapacity * sizeof(*threadPool)); in POOL_resize_internal()
217 ctx->threads = threadPool; in POOL_resize_internal()
221 if (ZSTD_pthread_create(&threadPool[threadId], NULL, &POOL_thread, ctx)) { in POOL_resize_internal()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestDispatchersTest.kt | 29 newSingleThreadContext("testSingleThread").use { threadPool -> in <lambda>() method
34 Dispatchers.setMain(threadPool) in <lambda>()
|
| /external/guava/android/guava-tests/test/com/google/common/cache/ |
| D | CacheBuilderTest.java | 499 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
505 threadPool.submit( 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/skia/tests/ |
| D | GrContextFactoryTest.cpp | 89 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1); in DEF_GPUTEST() local
90 contextOptions.fExecutor = threadPool.get(); in DEF_GPUTEST()
|
| /external/skqp/tests/ |
| D | GrContextFactoryTest.cpp | 124 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1); in DEF_GPUTEST() local
125 contextOptions.fExecutor = threadPool.get(); in DEF_GPUTEST()
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheBuilderTest.java | 575 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
581 threadPool.submit( in testRemovalNotification_clear_basher()
672 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
676 threadPool.submit( in testRemovalNotification_get_basher()
690 threadPool.shutdown(); in testRemovalNotification_get_basher()
691 threadPool.awaitTermination(300, SECONDS); in testRemovalNotification_get_basher()
|
| /external/guava/guava-tests/benchmark/com/google/common/collect/ |
| D | ConcurrentHashMultisetBenchmark.java | 58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
68 threadPool = in setUp()
99 futures.add(threadPool.submit(task));
|
| /external/guava/android/guava-tests/benchmark/com/google/common/collect/ |
| D | ConcurrentHashMultisetBenchmark.java | 58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
68 threadPool = in setUp()
99 futures.add(threadPool.submit(task));
|
| /external/mesa3d/src/gallium/drivers/swr/rasterizer/core/ |
| D | tilemgr.cpp | 113 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask); in GetHotTile()
137 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask); in GetHotTile()
346 HANDLE hWorkerPrivateData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in InitializeHotTiles()
|
| D | threads.cpp | 841 if (apiThreadId >= pContext->threadPool.numReservedThreads) in BindApiThread()
843 if (pContext->threadPool.numReservedThreads) in BindApiThread()
845 const THREAD_DATA& threadData = pContext->threadPool.pApiThreadData[0]; in BindApiThread()
852 const THREAD_DATA& threadData = pContext->threadPool.pApiThreadData[apiThreadId]; in BindApiThread()
888 uint32_t numaMask = pContext->threadPool.numaMask; in workerThreadMain()
|
| D | backend.cpp | 87 pContext->threadPool.pThreadData[workerId].pWorkerPrivateData, in ProcessComputeBE()
120 HANDLE hWorkerPrivateData = pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in ProcessStoreTileBE()
|
| D | api.cpp | 150 CreateThreadPool(pContext, &pContext->threadPool); in SwrCreateContext()
185 pContext->threadPool.pThreadData ? pContext->threadPool.pThreadData[i].numaId : 0; in SwrCreateContext()
201 …SWR_WORKER_DATA* pWorkerData = (SWR_WORKER_DATA*)pContext->threadPool.pThreadData[i].pWorkerPrivat… in SwrCreateContext()
226 StartThreadPool(pContext, &pContext->threadPool); in SwrCreateContext()
428 DestroyThreadPool(pContext, &pContext->threadPool); in SwrDestroyContext()
|
| D | frontend.cpp | 76 uint32_t numNumaNodes = pContext->threadPool.numaMask + 1; in ProcessShutdown()
78 for (uint32_t i = 0; i < pContext->threadPool.numThreads; ++i) in ProcessShutdown()
514 void* pWorkerData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in StreamOut()
833 void* pWorkerData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in GeometryShaderStage()
1269 void* pWorkerData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in TessellationStages()
1681 void* pWorkerData = pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in ProcessDraw()
|
| D | backend_clear.cpp | 161 HANDLE hWorkerPrivateData = pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in ProcessClearBE()
|
| D | context.h | 520 THREAD_POOL threadPool; // Thread pool associated with this context member
|
| D | backend_singlesample.cpp | 51 void* pWorkerData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in BackendSingleSample()
|
| D | backend_sample.cpp | 51 void* pWorkerData = pDC->pContext->threadPool.pThreadData[workerId].pWorkerPrivateData; in BackendSampleRate()
|
| D | backend_impl.h | 1038 void* pWorkerData = pContext->threadPool.pThreadData[workerId].pWorkerPrivateData;
|
| D | rasterizer_impl.h | 1435 HANDLE hWorkerPrivateData = pContext->threadPool.pThreadData[workerId].pWorkerPrivateData;
|