| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/src/ |
| H A D | MultithreadedDispatchers.common.kt | 34 newFixedThreadPoolContext(1, name)
62 public expect fun newFixedThreadPoolContext(nThreads: Int, name: String): CloseableCoroutineDispatc… method
|
| /aosp_15_r20/packages/apps/Launcher3/src/com/android/launcher3/util/coroutines/ |
| D | DispatcherProvider.kt | 22 import kotlinx.coroutines.newFixedThreadPoolContext
55 return newFixedThreadPoolContext( in bgDispatcher()
|
| /aosp_15_r20/frameworks/base/packages/SystemUI/src/com/android/systemui/util/kotlin/ |
| H A D | SysUICoroutinesModule.kt | 36 import kotlinx.coroutines.newFixedThreadPoolContext
74 newFixedThreadPoolContext( in bgApplicationScope()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/sync/ |
| H A D | MutexStressTest.kt | 25 newFixedThreadPoolContext(1, "testMultiThreadedContextWithSingleWorker").use { in <lambda>()
32 newFixedThreadPoolContext(8, "testMultiThreadedContext").use { in <lambda>()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/ |
| H A D | MultithreadedDispatcherStressTest.kt | 18 val dispatcher = newFixedThreadPoolContext(nThreads, "testMultiThreadedContext") in testClosingNotDroppingTasks()
|
| H A D | LimitedParallelismConcurrentTest.kt | 25 val executor = newFixedThreadPoolContext(targetParallelism, "test") in <lambda>()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| H A D | ThreadPoolDispatcher.kt | 9 public actual fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatch… in <lambda>() method
|
| /aosp_15_r20/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| H A D | ParametrizedDispatcherBase.kt | 31 … newFixedThreadPoolContext(dispatcher.substring(4).toInt(), dispatcher).also { closeable = it } in setup()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/nativeOther/src/ |
| H A D | Dispatchers.kt | 14 …private val ctx = newFixedThreadPoolContext(Platform.getAvailableProcessors().coerceAtLeast(2), "D… in createMainDispatcher()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| H A D | UnconfinedConcurrentStressTest.kt | 11 private val executor = newFixedThreadPoolContext(threads, "UnconfinedConcurrentStressTest") in <lambda>()
|
| H A D | JobChildStressTest.kt | 11 private val pool = newFixedThreadPoolContext(3, "JobChildStressTest") in <lambda>()
|
| H A D | JobActivationStressTest.kt | 11 private val pool = newFixedThreadPoolContext(3, "JobActivationStressTest")
|
| H A D | JoinStressTest.kt | 12 private val pool = newFixedThreadPoolContext(3, "JoinStressTest")
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/knit/ |
| H A D | ClosedAfterGuideTestExecutor.kt | 10 internal fun newFixedThreadPoolContext(nThreads: Int, name: String): ExecutorCoroutineDispatcher = in newSingleThreadContext() method
|
| /aosp_15_r20/external/kotlinx.coroutines/test-utils/jvm/src/ |
| H A D | ExecutorRule.kt | 21 _executor = newFixedThreadPoolContext(numberOfThreads, threadPrefix) in apply()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| H A D | Dispatchers.kt | 27 private val unlimitedPool = newFixedThreadPoolContext(2048, "Dispatchers.IO")
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| H A D | JobExceptionsStressTest.kt | 13 private val executor = newFixedThreadPoolContext(5, "JobExceptionsStressTest")
|
| H A D | WithContextCancellationStressTest.kt | 15 private val pool = newFixedThreadPoolContext(3, "WithContextCancellationStressTest")
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| H A D | InvokeOnCloseStressTest.kt | 16 private val pool = newFixedThreadPoolContext(3, "InvokeOnCloseStressTest")
|
| H A D | ConflatedChannelCloseStressTest.kt | 18 val pool = newFixedThreadPoolContext(nSenders + 2, "TestStressClose") in <lambda>()
|
| H A D | ChannelSelectStressTest.kt | 14 …private val dispatcher = newFixedThreadPoolContext(pairedCoroutines * 2, "ChannelSelectStressTest")
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/selects/ |
| H A D | SelectDeadlockStressTest.kt | 15 private val pool = newFixedThreadPoolContext(2, "SelectDeadlockStressTest") in <lambda>()
|
| /aosp_15_r20/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| H A D | PingPongWithBlockingContext.kt | 28 private val threadPool = newFixedThreadPoolContext(8, "PongCtx")
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| H A D | MultithreadedDispatchersTest.kt | 44 val dispatcher = newFixedThreadPoolContext(64, "test") in testNotAllocatingExtraDispatchers()
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| H A D | StateFlowStressTest.kt | 19 pool = newFixedThreadPoolContext(nEmitters + nCollectors, "StateFlowStressTest") in <lambda>()
|