| /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>()
156 corePoolSize = 1 in <lambda>()
|
| D | SchedulerTestBase.kt | 59 protected var corePoolSize = CORES_COUNT variable
68 corePoolSize,
|
| D | LimitingDispatcherTest.kt | 25 corePoolSize = 3 in testBlockingInterleave()
|
| 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 | Deprecated.kt | 25 private val corePoolSize: Int, constant in kotlinx.coroutines.scheduling.ExperimentalCoroutineDispatcher
31 corePoolSize: Int = CORE_POOL_SIZE,
34 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS, schedulerName)
38 corePoolSize: Int = CORE_POOL_SIZE,
40 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS)
93 …require(parallelism <= corePoolSize) { "Expected parallelism level lesser than core pool size ($co… in limited()
108 …private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveN… in createScheduler()
|
| 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>()
269 val workers = ResizableAtomicArray<Worker>((corePoolSize + 1) * 2) in <lambda>()
278 private val controlState = atomic(corePoolSize.toLong() shl CPU_PERMITS_SHIFT) in <lambda>()
375 assert { availableCpuPermits == corePoolSize } in <lambda>()
452 if (cpuWorkers < corePoolSize) { in <lambda>()
456 if (newCpuWorkers == 1 && corePoolSize > 1) createNewWorker() in <lambda>()
[all …]
|
| D | Dispatcher.kt | 97 private val corePoolSize: Int = CORE_POOL_SIZE, in toString() constant in kotlinx.coroutines.scheduling.SchedulerCoroutineDispatcher
110 CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveNs, schedulerName) in toString()
|
| /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/libtextclassifier/java/src/com/android/textclassifier/common/ |
| D | TextClassifierServiceExecutors.java | 79 private static ListeningExecutorService init(String nameFormat, int priority, int corePoolSize) { in init() argument
83 corePoolSize, in init()
|
| /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/cronet/base/android/java/src/org/chromium/base/task/ |
| D | ChromeThreadPoolExecutor.java | 54 ChromeThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, in ChromeThreadPoolExecutor() argument
56 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory); in ChromeThreadPoolExecutor()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 85 …DEFAULT({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolSize =… in parallelism()
|
| D | ChannelProducerConsumerBenchmark.kt | 141 …DEFAULT({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolSize =… in parallelism()
|
| /external/ow2-asm/tools/retrofitter/src/main/resources/ |
| D | jdk1.5.0.12.txt.gz | |