| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherMixedStealingStressTest.kt | 25 val blocking = blockingDispatcher(corePoolSize).asExecutor() in testBlockingProgressPreventedInternal()
28 val cpuBlocker = CyclicBarrier(corePoolSize + 1) in testBlockingProgressPreventedInternal()
32 repeat(corePoolSize - 1) { in testBlockingProgressPreventedInternal()
53 val blocking = blockingDispatcher(corePoolSize).asExecutor() in testBlockingProgressPreventedExternal()
56 val cpuBlocker = CyclicBarrier(corePoolSize + 1) in testBlockingProgressPreventedExternal()
58 repeat(corePoolSize) { in testBlockingProgressPreventedExternal()
67 if (waiters >= corePoolSize) break in testBlockingProgressPreventedExternal()
|
| D | CoroutineDispatcherTest.kt | 22 corePoolSize = 1 in <lambda>()
43 corePoolSize = 1 in <lambda>()
57 corePoolSize = 2 in <lambda>()
79 corePoolSize = 2 in <lambda>()
91 corePoolSize = 1 in <lambda>()
99 corePoolSize = 1 in <lambda>()
|
| D | BlockingCoroutineDispatcherTest.kt | 109 corePoolSize = 4 in <lambda>()
130 corePoolSize = 1 in <lambda>()
159 corePoolSize = 1 in testBoundedBlockingFairness()
195 corePoolSize = 1 in <lambda>()
221 corePoolSize = 1 in <lambda>()
|
| D | LimitingDispatcherTest.kt | 15 view(corePoolSize + 1) in testTooLargeView()
30 corePoolSize = 3 in testBlockingInterleave()
|
| D | SchedulerTestBase.kt | 68 protected var corePoolSize = CORES_COUNT variable
77 corePoolSize,
|
| D | BlockingCoroutineDispatcherLivenessStressTest.kt | 48 corePoolSize = CORES_COUNT in <lambda>()
|
| D | LimitingCoroutineDispatcherStressTest.kt | 16 corePoolSize = 3
|
| D | BlockingCoroutineDispatcherThreadLimitStressTest.kt | 17 corePoolSize = CORES_COUNT
|
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 65 corePoolSize = 2 // Easier to reproduce race with unparks in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 41 private val corePoolSize: Int, in toString() constant in kotlinx.coroutines.scheduling.ExperimentalCoroutineDispatcher
47 corePoolSize: Int = CORE_POOL_SIZE, in toString()
50 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS, schedulerName) in toString()
54 corePoolSize: Int = CORE_POOL_SIZE, in toString()
56 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS) in toString()
109 …require(parallelism <= corePoolSize) { "Expected parallelism level lesser than core pool size ($co… in toString()
124 …private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveN… in toString()
|
| D | CoroutineScheduler.kt | 93 @JvmField val corePoolSize: Int, in <lambda>() constant in kotlinx.coroutines.scheduling.CoroutineScheduler
99 require(corePoolSize >= MIN_SUPPORTED_POOL_SIZE) { in <lambda>()
100 "Core pool size $corePoolSize should be at least $MIN_SUPPORTED_POOL_SIZE" in <lambda>()
102 require(maxPoolSize >= corePoolSize) { in <lambda>()
103 … "Max pool size $maxPoolSize should be greater than or equals to core pool size $corePoolSize" in <lambda>()
270 private val controlState = atomic(corePoolSize.toLong() shl CPU_PERMITS_SHIFT) in <lambda>()
366 assert { availableCpuPermits == corePoolSize } in <lambda>()
439 if (cpuWorkers < corePoolSize) { in <lambda>()
443 if (newCpuWorkers == 1 && corePoolSize > 1) createNewWorker() in <lambda>()
472 if (cpuWorkers >= corePoolSize) return 0 in <lambda>()
[all …]
|
| /external/libtextclassifier/java/src/com/android/textclassifier/common/ |
| D | TextClassifierServiceExecutors.java | 54 private static ListeningExecutorService init(String nameFormat, int priority, int corePoolSize) { in init() argument
58 corePoolSize, in init()
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| D | GraphThreadPoolExecutor.java | 34 …c GraphThreadPoolExecutor(DynamicGraph<T> graph, IThreadWorkerFactory<T> factory, int corePoolSize, in GraphThreadPoolExecutor() argument
36 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue in GraphThreadPoolExecutor()
38 ppp("Initializing executor with " + corePoolSize + " threads and following graph " + graph); in GraphThreadPoolExecutor()
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
| D | FifoPriorityThreadPoolExecutor.java | 30 …public FifoPriorityThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAlive, TimeU… in FifoPriorityThreadPoolExecutor() argument
32 …super(corePoolSize, maximumPoolSize, keepAlive, timeUnit, new PriorityBlockingQueue<Runnable>(), t… in FifoPriorityThreadPoolExecutor()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 87 …EXPERIMENTAL({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolS… in parallelism()
|