| /aosp_15_r20/build/soong/finder/ |
| H A D | finder.go | 158 threadPool *threadPool member
607 type threadPool struct { struct
608 receivedRequests sync.WaitGroup
609 activeRequests semaphore
620 func (p *threadPool) Run(function func()) {
642 func (p *threadPool) Wait() {
|
| /aosp_15_r20/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| H A D | PingPongWithBlockingContext.kt | 28 private val threadPool = newFixedThreadPoolContext(8, "PongCtx") constant
|
| /aosp_15_r20/libcore/luni/src/test/java/tests/java/sql/ |
| H A D | StressTest.java | 140 ThreadPool threadPool = new ThreadPool(numTasks); in testManyConnectionsUsingManyThreads() local
217 ThreadPool threadPool = new ThreadPool(numConnections); in testInsertOfManyRowsUsingManyThreads() local
|
| H A D | MultiThreadAccessTest.java | 45 private ThreadPool threadPool; field in MultiThreadAccessTest
|
| /aosp_15_r20/tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/ |
| H A D | BatchProcessor.kt | 87 private val threadPool = Array(ThreadCount) { in <lambda>() constant
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/cache/ |
| H A D | CacheBuilderTest.java | 496 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
596 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/cache/ |
| H A D | CacheBuilderTest.java | 505 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_clear_basher() local
605 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testRemovalNotification_get_basher() local
|
| /aosp_15_r20/external/guava/android/guava-tests/benchmark/com/google/common/collect/ |
| H A D | ConcurrentHashMultisetBenchmark.java | 58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
|
| /aosp_15_r20/external/guava/guava-tests/benchmark/com/google/common/collect/ |
| H A D | ConcurrentHashMultisetBenchmark.java | 58 private ExecutorService threadPool; field in ConcurrentHashMultisetBenchmark
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | AtomicLongMapBasherTest.java | 50 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | AtomicLongMapBasherTest.java | 50 ExecutorService threadPool = Executors.newFixedThreadPool(nThreads); in testModify_basher() local
|
| /aosp_15_r20/external/apache-commons-lang/src/test/java/org/apache/commons/lang3/builder/ |
| H A D | ReflectionToStringBuilderConcurrencyTest.java | 91 final ExecutorService threadPool = Executors.newFixedThreadPool(2); in testConcurrency() local
|
| H A D | ToStringStyleConcurrencyTest.java | 90 final ExecutorService threadPool = Executors.newFixedThreadPool(2); in testConcurrency() local
|
| /aosp_15_r20/external/tink/java_src/src/test/java/com/google/crypto/tink/internal/ |
| H A D | MutablePrimitiveRegistryMultithreadTest.java | 112 ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_NUMBER); in registerAndGetPrimitivesInParallel_works() local
|
| H A D | MutableSerializationRegistryMultithreadTest.java | 218 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndParseAndSerializeInParallel_works() local
|
| /aosp_15_r20/packages/apps/Camera2/src/com/android/camera/one/v2/autofocus/ |
| D | ManualAutoFocusFactory.java | 77 ScheduledExecutorService threadPool, in create()
|
| /aosp_15_r20/external/skia/tests/ |
| H A D | GrContextFactoryTest.cpp | 92 std::unique_ptr<SkExecutor> threadPool = SkExecutor::MakeFIFOThreadPool(1); in DEF_GANESH_TEST() local
|
| /aosp_15_r20/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| H A D | CrtMemoryLeakDetector.java | 190 final ExecutorService threadPool = Executors.newFixedThreadPool(numThreads); in runViaThreadPool() local
|
| H A D | Http2StreamManagerTest.java | 88 final ExecutorService threadPool = Executors.newFixedThreadPool(numThreads); in testParallelStreams() local
|
| /aosp_15_r20/frameworks/base/core/tests/coretests/src/com/android/internal/os/ |
| H A D | KernelCpuUidBpfMapReaderTest.java | 124 ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(11); in testConcurrent() local
|
| /aosp_15_r20/external/tink/java_src/src/test/java/com/google/crypto/tink/ |
| H A D | RegistryMultithreadTest.java | 181 ExecutorService threadPool = Executors.newFixedThreadPool(4); in registerAndGetKeyManager_works() local
|
| /aosp_15_r20/external/zstd/programs/ |
| H A D | fileio_asyncio.h | 40 POOL_ctx* threadPool; member
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-test/jvm/test/ |
| H A D | MultithreadingTest.kt | 25 newSingleThreadContext("testSingleThread").use { threadPool -> in <lambda>() method
|
| /aosp_15_r20/packages/modules/RemoteKeyProvisioning/app/src/com/android/rkpdapp/service/ |
| D | RegistrationBinder.java | 76 Provisioner provisioner, ExecutorService threadPool) { in RegistrationBinder()
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/collect/ |
| H A D | QueuesTest.java | 71 private ExecutorService threadPool; field in QueuesTest
|