async/ktx.async/AsyncExecutorDispatcher

AsyncExecutorDispatcher

class AsyncExecutorDispatcher(val executor: AsyncExecutor, val threads: Int = -1) : AbstractKtxDispatcher, Closeable, Disposable

A CoroutineDispatcher that wraps around libGDX AsyncExecutor instance (available via executor property) to execute tasks asynchronously. threads property is purely informational and cannot be verified, since AsyncExecutor does not expose the amount of threads it uses internally; provide a valid threads amount during initiation or use the official factory methods to prevent from mismatches with the actual max threads amount.

Uses libGDX Timer API to support delay.

Constructors

AsyncExecutorDispatcher

constructor(executor: AsyncExecutor, threads: Int = -1)

Properties

val executor: AsyncExecutor

open override val key: CoroutineContext.Key<*>

val threads: Int

Functions

open override fun close()

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

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

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

open override fun dispose()

open override fun execute(block: Runnable)

Immediately executes or schedules execution of the passed block.

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

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

interceptContinuation

override 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

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

open operator fun plus(context: CoroutineContext): CoroutineContext

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

releaseInterceptedContinuation

override fun releaseInterceptedContinuation(continuation: Continuation<*>)

scheduleResumeAfterDelay

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

open override fun toString(): String