| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 55 private ExecutorService threadPool; field in QueuesTest
59 threadPool = Executors.newCachedThreadPool(); in setUp()
66 threadPool.shutdown(); in tearDown()
68 threadPool.awaitTermination(1, TimeUnit.SECONDS)); in tearDown()
87 threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
88 threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
89 threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
90 threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
91 threadPool.submit(new Producer(q, 20)); in testMultipleProducers()
112 Future<?> submitter = threadPool.submit(new Producer(q, 1)); in testDrainTimesOut()
[all …]
|
| D | MapMakerTest.java | 138 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
142 threadPool.submit(new Runnable() { in testRemovalNotification_clear_basher()
|
| /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/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheBuilderTest.java | 476 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
480 threadPool.submit(new Runnable() { in testRemovalNotification_clear_basher()
565 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
567 threadPool.submit(new Runnable() { in testRemovalNotification_get_basher()
579 threadPool.shutdown(); in testRemovalNotification_get_basher()
580 threadPool.awaitTermination(300, TimeUnit.SECONDS); in testRemovalNotification_get_basher()
|
| /external/skia/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/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/benchmark/com/google/common/collect/ |
| D | ConcurrentHashMultisetBenchmark.java | 56 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
65 threadPool = in setUp()
92 futures.add(threadPool.submit(task));
|
| /external/mesa3d/src/gallium/drivers/swr/rasterizer/core/ |
| D | threads.cpp | 744 if (apiThreadId >= pContext->threadPool.numReservedThreads) in BindApiThread()
746 if (pContext->threadPool.numReservedThreads) in BindApiThread()
748 const THREAD_DATA &threadData = pContext->threadPool.pApiThreadData[0]; in BindApiThread()
755 const THREAD_DATA &threadData = pContext->threadPool.pApiThreadData[apiThreadId]; in BindApiThread()
787 uint32_t numaMask = pContext->threadPool.numaMask; in workerThreadMain()
|
| D | tilemgr.cpp | 102 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask); in GetHotTile()
126 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask); in GetHotTile()
|
| D | api.cpp | 130 CreateThreadPool(pContext, &pContext->threadPool); in SwrCreateContext()
151 uint32_t numaNode = pContext->threadPool.pThreadData ? in SwrCreateContext()
152 pContext->threadPool.pThreadData[i].numaId : 0; in SwrCreateContext()
194 StartThreadPool(pContext, &pContext->threadPool); in SwrCreateContext()
393 DestroyThreadPool(pContext, &pContext->threadPool); in SwrDestroyContext()
|
| D | context.h | 481 THREAD_POOL threadPool; // Thread pool associated with this context member
|
| D | frontend.cpp | 92 uint32_t numNumaNodes = pContext->threadPool.numaMask + 1; in ProcessShutdown()
94 for (uint32_t i = 0; i < pContext->threadPool.numThreads; ++i) in ProcessShutdown()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AtomicLongMapTest.java | 568 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
570 threadPool.submit(new Runnable() { in testModify_basher()
630 threadPool.shutdown(); in testModify_basher()
631 assertTrue(threadPool.awaitTermination(300, TimeUnit.SECONDS)); in testModify_basher()
|