modulecheck-utils:coroutines:impl/modulecheck.utils.coroutines.impl/LimitedDispatcherImpl

LimitedDispatcherImpl

class LimitedDispatcherImpl(val dispatcher: CoroutineDispatcher, val parallelism: Int) : LimitedDispatcher, Runnable(source)

Forked from kotlinx.coroutines

The result of .limitedParallelism(x) call, a dispatcher that wraps the given dispatcher, but limits the parallelism level, while trying to emulate fairness.

Since

0.12.0

Constructors

LimitedDispatcherImpl

constructor(dispatcher: CoroutineDispatcher, parallelism: Int)

Properties

dispatcher

private val dispatcher: CoroutineDispatcher

key

open override val key: CoroutineContext.Key<*>

parallelism

private val parallelism: Int

queue

private val queue: LockFreeTaskQueue<Runnable>

runningWorkers

@Volatile

private var runningWorkers: Int

workerAllocationLock

private val workerAllocationLock: Any

Functions

addAndTryDispatching

private fun addAndTryDispatching(block: Runnable): Boolean

dispatch

open override fun dispatch(context: CoroutineContext, block: Runnable)

dispatchInternal

private inline fun dispatchInternal(block: Runnable, dispatch: () -> Unit)

dispatchYield

open override fun dispatchYield(context: CoroutineContext, block: Runnable)

fold

open override fun <R> fold(initial: R, operation: (R, CoroutineContext.Element) -> R): R

get

open operator override fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E?

interceptContinuation

override fun <T> interceptContinuation(continuation: Continuation<T>): Continuation<T>

isDispatchNeeded

open fun isDispatchNeeded(context: CoroutineContext): Boolean

limitedParallelism

@ExperimentalCoroutinesApi

open override fun limitedParallelism(parallelism: Int): CoroutineDispatcher

minusKey

open override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext

plus

open operator fun plus(context: CoroutineContext): CoroutineContext

operator fun ~~plus~~(other: CoroutineDispatcher): CoroutineDispatcher

releaseInterceptedContinuation

override fun releaseInterceptedContinuation(continuation: Continuation<*>)

run

open override fun run()

toString

open override fun toString(): String

tryAllocateWorker

private fun tryAllocateWorker(): Boolean