HomeSort by relevance Sort by last modified time
    Searched refs:threadPool (Results 1 - 16 of 16) sorted by null

  /external/guava/guava-tests/test/com/google/common/collect/
QueuesTest.java 55 private ExecutorService threadPool;
59 threadPool = Executors.newCachedThreadPool();
66 threadPool.shutdown();
68 threadPool.awaitTermination(1, TimeUnit.SECONDS));
87 threadPool.submit(new Producer(q, 20));
88 threadPool.submit(new Producer(q, 20));
89 threadPool.submit(new Producer(q, 20));
90 threadPool.submit(new Producer(q, 20));
91 threadPool.submit(new Producer(q, 20));
112 Future<?> submitter = threadPool.submit(new Producer(q, 1))
    [all...]
MapMakerTest.java 138 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
142 threadPool.submit(new Runnable() {
  /external/skia/tests/
GrContextFactoryTest.cpp 124 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1);
125 contextOptions.fExecutor = threadPool.get();
  /external/skqp/tests/
GrContextFactoryTest.cpp 124 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1);
125 contextOptions.fExecutor = threadPool.get();
  /external/guava/guava-tests/test/com/google/common/cache/
CacheBuilderTest.java 476 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
480 threadPool.submit(new Runnable() {
565 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
567 threadPool.submit(new Runnable() {
579 threadPool.shutdown();
580 threadPool.awaitTermination(300, TimeUnit.SECONDS);
  /external/guava/guava-tests/benchmark/com/google/common/collect/
ConcurrentHashMultisetBenchmark.java 56 private ExecutorService threadPool;
65 threadPool =
92 futures.add(threadPool.submit(task));
  /external/grpc-grpc/src/csharp/Grpc.Core/
GrpcEnvironment.cs 59 readonly GrpcThreadPool threadPool;
305 threadPool = new GrpcThreadPool(this, GetThreadPoolSizeOrDefault(), GetCompletionQueueCountOrDefault(), inlineHandlers);
306 threadPool.Start();
316 return this.threadPool.CompletionQueues;
328 return this.threadPool.IsAlive;
338 var cqIndex = (int) ((cqPickerCounter.Increment() - 1) % this.threadPool.CompletionQueues.Count);
339 return this.threadPool.CompletionQueues.ElementAt(cqIndex);
397 await threadPool.StopAsync().ConfigureAwait(false);
  /build/soong/finder/
finder.go 151 threadPool *threadPool
373 f.threadPool = newThreadPool(f.numDbLoadingThreads)
382 f.threadPool = nil
596 // A threadPool runs goroutines and supports throttling and waiting.
599 type threadPool struct {
604 func newThreadPool(maxNumConcurrentThreads int) *threadPool {
605 return &threadPool{
612 func (p *threadPool) Run(function func()) {
614 // If Run() was called from within a goroutine spawned by this threadPool,
    [all...]
  /external/mesa3d/src/gallium/drivers/swr/rasterizer/core/
threads.cpp 744 if (apiThreadId >= pContext->threadPool.numReservedThreads)
746 if (pContext->threadPool.numReservedThreads)
748 const THREAD_DATA &threadData = pContext->threadPool.pApiThreadData[0];
755 const THREAD_DATA &threadData = pContext->threadPool.pApiThreadData[apiThreadId];
787 uint32_t numaMask = pContext->threadPool.numaMask;
    [all...]
tilemgr.cpp 102 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask);
126 uint32_t numaNode = ((x ^ y) & pContext->threadPool.numaMask);
api.cpp 130 CreateThreadPool(pContext, &pContext->threadPool);
151 uint32_t numaNode = pContext->threadPool.pThreadData ?
152 pContext->threadPool.pThreadData[i].numaId : 0;
194 StartThreadPool(pContext, &pContext->threadPool);
393 DestroyThreadPool(pContext, &pContext->threadPool);
    [all...]
context.h 481 THREAD_POOL threadPool; // Thread pool associated with this context
frontend.cpp 92 uint32_t numNumaNodes = pContext->threadPool.numaMask + 1;
94 for (uint32_t i = 0; i < pContext->threadPool.numThreads; ++i)
    [all...]
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
AtomicLongMapTest.java 568 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads);
570 threadPool.submit(new Runnable() {
630 threadPool.shutdown();
631 assertTrue(threadPool.awaitTermination(300, TimeUnit.SECONDS));
  /external/guice/extensions/struts2/lib/
jetty-6.1.0.jar 
jsp-2.1.jar 

Completed in 3575 milliseconds