Searched refs:newFixedThreadPoolContext (Results 1 – 25 of 25) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | ThreadPoolDispatcher.kt | 36 newFixedThreadPoolContext(1, name) in <lambda>()
62 public fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatcher { in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | UnconfinedConcurrentStressTest.kt | 14 private val executor = newFixedThreadPoolContext(threads, "UnconfinedConcurrentStressTest") in <lambda>()
|
| D | ExecutorRule.kt | 23 _executor = newFixedThreadPoolContext(numberOfThreads, threadPrefix) in apply()
|
| D | JobChildStressTest.kt | 14 private val pool = newFixedThreadPoolContext(3, "JobChildStressTest") in <lambda>()
|
| D | JobActivationStressTest.kt | 14 private val pool = newFixedThreadPoolContext(3, "JobActivationStressTest")
|
| D | JoinStrTest.kt | 15 private val pool = newFixedThreadPoolContext(3, "JoinStressTest")
|
| D | ExecutorsTest.kt | 29 val context = newFixedThreadPoolContext(2, "TestPool") in <lambda>()
|
| D | RunBlockingTest.kt | 72 fun testCancellation() = newFixedThreadPoolContext(2, "testCancellation").use { in testCancellation()
|
| D | FailingCoroutinesMachineryTest.kt | 37 private val lazyOuterDispatcher = lazy { newFixedThreadPoolContext(1, "") } in <lambda>()
|
| D | ThreadLocalTest.kt | 16 private val executor = newFixedThreadPoolContext(1, "threadLocalTest")
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ParametrizedDispatcherBase.kt | 36 … newFixedThreadPoolContext(dispatcher.substring(4).toInt(), dispatcher).also { closeable = it } in setup()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | JobExceptionsStressTest.kt | 15 private val executor = newFixedThreadPoolContext(5, "JobExceptionsStressTest")
|
| D | WithContextCancellationStressTest.kt | 17 private val pool = newFixedThreadPoolContext(3, "WithContextCancellationStressTest")
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | InvokeOnCloseStressTest.kt | 20 private val pool = newFixedThreadPoolContext(3, "InvokeOnCloseStressTest")
|
| D | ConflatedChannelCloseStressTest.kt | 24 val pool = newFixedThreadPoolContext(nSenders + 2, "TestStressClose") in <lambda>()
|
| D | ChannelSelectStressTest.kt | 17 …private val dispatcher = newFixedThreadPoolContext(pairedCoroutines * 2, "ChannelSelectStressTest")
|
| D | BroadcastChannelMultiReceiveStressTest.kt | 32 …private val pool = newFixedThreadPoolContext(nReceivers + 1, "BroadcastChannelMultiReceiveStressTe… in <lambda>()
|
| D | ChannelSendReceiveStressTest.kt | 48 newFixedThreadPoolContext(nSenders + nReceivers, "ChannelSendReceiveStressTest") in <lambda>()
|
| D | ChannelUndeliveredElementStressTest.kt | 35 private val dispatcher = newFixedThreadPoolContext(2, "ChannelAtomicCancelStressTest") in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/selects/ |
| D | SelectDeadlockStressTest.kt | 18 private val pool = newFixedThreadPoolContext(2, "SelectDeadlockStressTest") in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongWithBlockingContext.kt | 34 private val threadPool = newFixedThreadPoolContext(8, "PongCtx")
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | StateFlowStressTest.kt | 22 pool = newFixedThreadPoolContext(nEmitters + nCollectors, "StateFlowStressTest") in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/ |
| D | README.md | 21 | [newFixedThreadPoolContext] | Creates a thread pool of a fixed size
109 [newFixedThreadPoolContext]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/ko…
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 845 * No `Job` in `newSingleThreadContext` and `newFixedThreadPoolContext` anymore (see #149, #151):
847 …`newFixedThreadPoolContext` invocation. They both used to return a combination of dispatcher + job,
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 527 …public static final fun newFixedThreadPoolContext (ILjava/lang/String;)Lkotlinx/coroutines/Executo…
|