OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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