core/com.lehaine.littlekt.async/AsyncThreadDispatcher

AsyncThreadDispatcher

class AsyncThreadDispatcher(val executor: AsyncExecutor, val threads: Int = -1) : CoroutineDispatcher, KtDispatcher, Disposable

A CoroutineDispatcher that wraps around an AsyncExecutor instance (executor) to execute tasks asynchronously.

Requires calling executePending in order to support delay.

Constructors

fun AsyncThreadDispatcher(executor: AsyncExecutor, threads: Int = -1)

Functions

delay

open suspend fun ~~delay~~(time: Long)

dispatch

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

dispatchYield

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

dispose

open override fun dispose()

execute

open override fun execute(block: Runnable)

Immediately executes the passed block.

executePending

fun executePending()

Executes any pending timed (delay) or queued (queue) tasks.

fold

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

get

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

interceptContinuation

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

invokeOnTimeout

open override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): DisposableHandle

isDispatchNeeded

open fun isDispatchNeeded(context: CoroutineContext): Boolean

limitedParallelism

open fun limitedParallelism(parallelism: Int): CoroutineDispatcher

minusKey

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

plus

open operator fun plus(context: CoroutineContext): CoroutineContext

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

queue

open override fun queue(block: Runnable)

Schedules the execution of the passed block.

releaseInterceptedContinuation

fun releaseInterceptedContinuation(continuation: Continuation<*>)

scheduleResumeAfterDelay

open override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit>)

toString

open override fun toString(): String

Properties

executor

val executor: AsyncExecutor

threads

val threads: Int