Searched refs:maxPoolSize (Results 1 – 7 of 7) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 42 private val maxPoolSize: Int, in toString() constant in kotlinx.coroutines.scheduling.ExperimentalCoroutineDispatcher
48 maxPoolSize: Int = MAX_POOL_SIZE, in toString()
50 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS, schedulerName) in toString()
55 maxPoolSize: Int = MAX_POOL_SIZE in toString()
56 ) : this(corePoolSize, maxPoolSize, IDLE_WORKER_KEEP_ALIVE_NS) in toString()
124 …private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveN… in toString()
|
| D | CoroutineScheduler.kt | 94 @JvmField val maxPoolSize: Int, in <lambda>() constant in kotlinx.coroutines.scheduling.CoroutineScheduler
102 require(maxPoolSize >= corePoolSize) { in <lambda>()
103 … "Max pool size $maxPoolSize should be greater than or equals to core pool size $corePoolSize" in <lambda>()
105 require(maxPoolSize <= MAX_SUPPORTED_POOL_SIZE) { in <lambda>()
106 …"Max pool size $maxPoolSize should not exceed maximal supported number of threads $MAX_SUPPORTED_P… in <lambda>()
264 val workers = AtomicReferenceArray<Worker?>(maxPoolSize + 1) in <lambda>()
473 if (created >= maxPoolSize) return 0 in <lambda>()
552 "max = $maxPoolSize}, " + in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | BlockingCoroutineDispatcherTest.kt | 131 maxPoolSize = 1 in <lambda>()
160 maxPoolSize = 1 in testBoundedBlockingFairness()
196 maxPoolSize = 1 in <lambda>()
222 maxPoolSize = 1 in <lambda>()
|
| D | SchedulerTestBase.kt | 69 protected var maxPoolSize = 1024 variable in kotlinx.coroutines.scheduling.SchedulerTestBase
78 maxPoolSize,
|
| D | CoroutineDispatcherTest.kt | 92 maxPoolSize = 4 in <lambda>()
100 maxPoolSize = 1 in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | SemaphoreBenchmark.kt | 87 …llelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolSize = parallelism) … in parallelism()
|
| /external/smali/dexlib2/src/main/java/org/jf/dexlib2/writer/ |
| D | DexWriter.java | 289 public boolean hasOverflowed(int maxPoolSize) {
291 if (section.getItemCount() > maxPoolSize) return true;
|