| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | LimitedParallelismSharedTest.kt | 16 val view = Dispatchers.Default.limitedParallelism(1) in <lambda>()
17 val view2 = Dispatchers.Default.limitedParallelism(1) in <lambda>()
29 assertFailsWith<IllegalArgumentException> { Dispatchers.Default.limitedParallelism(0) } in testParallelismSpec()
30 assertFailsWith<IllegalArgumentException> { Dispatchers.Default.limitedParallelism(-1) } in testParallelismSpec()
31 …assertFailsWith<IllegalArgumentException> { Dispatchers.Default.limitedParallelism(Int.MIN_VALUE) } in testParallelismSpec()
32 Dispatchers.Default.limitedParallelism(Int.MAX_VALUE) in testParallelismSpec()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 19 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in limitedParallelism() method
22 return super.limitedParallelism(parallelism) in limitedParallelism()
51 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in toString() method
54 return super.limitedParallelism(parallelism) in toString()
61 private val default = UnlimitedIoScheduler.limitedParallelism(
74 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in execute() method
76 return UnlimitedIoScheduler.limitedParallelism(parallelism) in execute()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | LimitedParallelismStressTest.kt | 39 val view = executor.limitedParallelism(targetParallelism) in <lambda>()
51 val view = Dispatchers.IO.limitedParallelism(targetParallelism) in <lambda>()
63 val view = Dispatchers.IO.limitedParallelism(targetParallelism) in <lambda>()
74 val view = executor.limitedParallelism(targetParallelism) in <lambda>()
|
| D | LimitedParallelismUnhandledExceptionTest.kt | 24 val view = executor.limitedParallelism(1) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| D | LimitedParallelismConcurrentTest.kt | 29 val view = executor.limitedParallelism(targetParallelism) in <lambda>()
51 val view = executor.limitedParallelism(1) in <lambda>()
52 val view2 = executor.limitedParallelism(1) in <lambda>()
83 val view = dispatcher.limitedParallelism(1) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Dispatchers.kt | 32 private val io = unlimitedPool.limitedParallelism(64) // Default JVM size
35 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in limitedParallelism() method
37 return unlimitedPool.limitedParallelism(parallelism) in limitedParallelism()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | LimitedDispatcher.kt | 41 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in <lambda>() method
44 return super.limitedParallelism(parallelism) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | SchedulerTestBase.kt | 88 return _dispatcher!!.limitedParallelism(parallelism) in view()
112 }.limitedParallelism(parallelism) in blocking()
|
| D | DefaultDispatchersTest.kt | 30 val limited = Dispatchers.IO.limitedParallelism(EXPECTED_PARALLELISM) in <lambda>()
|
| D | CoroutineSchedulerCloseStressTest.kt | 49 Mode.CPU_LIMITED -> closeableDispatcher.limitedParallelism(N_THREADS) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | MainCoroutineDispatcher.kt | 56 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in toString() method in kotlinx.coroutines.MainCoroutineDispatcher
|
| D | Unconfined.kt | 16 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in limitedParallelism() method
|
| D | CoroutineDispatcher.kt | 105 public open fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in isDispatchNeeded() method in kotlinx.coroutines.CoroutineDispatcher
|
| D | EventLoop.common.kt | 117 final override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in <lambda>() method in kotlinx.coroutines.EventLoop
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongWithBlockingContext.kt | 31 private val blocking = Dispatchers.IO.limitedParallelism(8)
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | MainDispatchers.kt | 98 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher = in isDispatchNeeded() method in kotlinx.coroutines.internal.MissingMainCoroutineDispatcher
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 68 * `Dispatchers.IO.limitedParallelism(valueLargerThanIOSize)` no longer creates an additional wrappe…
82 * Fixed a bug that allowed `limitedParallelism` to perform dispatches even after the underlying dis…
|
| D | CHANGES_UP_TO_1.7.md | 50 * `Dispatchers.IO.limitedParallelism(valueLargerThanIOSize)` no longer creates an additional wrappe…
64 * Fixed a bug that allowed `limitedParallelism` to perform dispatches even after the underlying dis…
87 * Fixed a bug that allowed `limitedParallelism` to perform dispatches even after the underlying dis…
135 * `Dispatchers.IO.limitedParallelism(valueLargerThanIOSize)` no longer creates an additional wrappe…
179 * Fixed a bug with `limitedParallelism` on K/N with new memory model throwing `ClassCastException` …
197 * Introduced `CoroutineDispatcher.limitedParallelism` that allows obtaining a view of the original …
198 * `Dispatchers.IO.limitedParallelism` usages ignore the bound on the parallelism level of `Dispatch…
275 * Introduced `CoroutineDispatcher.limitedParallelism` that allows obtaining a view of the original …
276 * `Dispatchers.IO.limitedParallelism` usages ignore the bound on the parallelism level of `Dispatch…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | JSDispatcher.kt | 34 override fun limitedParallelism(parallelism: Int): CoroutineDispatcher { in <lambda>() method in kotlinx.coroutines.SetTimeoutBasedDispatcher
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 180 public fun limitedParallelism (I)Lkotlinx/coroutines/CoroutineDispatcher;
516 public fun limitedParallelism (I)Lkotlinx/coroutines/CoroutineDispatcher;
|