korlibs-concurrent/korlibs.concurrent.thread/NativeThreadDispatcher

NativeThreadDispatcher

class NativeThreadDispatcher(val name: String = "NativeThreadDispatcher", val priority: NativeThreadPriority = NativeThreadPriority.NORMAL, val isDaemon: Boolean = true, val preciseTimings: Boolean = false) : CoroutineDispatcher, AutoCloseable, Delay

Constructors

NativeThreadDispatcher

constructor(name: String = "NativeThreadDispatcher", priority: NativeThreadPriority = NativeThreadPriority.NORMAL, isDaemon: Boolean = true, preciseTimings: Boolean = false)

Types

class TimedTask(val dispatcher: NativeThreadDispatcher, val time: FastDuration, val task: Continuation<Unit>?, val block: Runnable?) : Comparable<NativeThreadDispatcher.TimedTask> , DisposableHandle

Properties

val isDaemon: Boolean

open override val key: CoroutineContext.Key<*>

val name: String

val numTasks: Int

val numTimedTasks: Int

val preciseTimings: Boolean

val CoroutineContext.preferSyncIo: Boolean

val priority: NativeThreadPriority

var running: Boolean

val tasks: ArrayDeque<Runnable>

val tasksLock: Lock

val thread: NativeThread

val timedTasks: ArrayDeque<NativeThreadDispatcher.TimedTask>

val timedTasksLock: SynchronizedObject

Functions

fun CoroutineContext.androidContext(): Context

androidContextOrNull

fun CoroutineContext.androidContextOrNull(): Context?

open override fun close()

fun CoroutineDispatcher.close()

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

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

@InternalCoroutinesApi

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

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 override fun isDispatchNeeded(context: CoroutineContext): Boolean

limitedParallelism

open fun limitedParallelism(parallelism: Int, name: String?): CoroutineDispatcher

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

fun CoroutineContext.onCancel(check: () -> Boolean = { true }, block: (cancelled: Boolean) -> Unit): AutoCloseable

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