korlibs-concurrent/korlibs.concurrent.thread

Package-level declarations

Types

FixedPoolNativeThreadDispatcher

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

NativeNativeThread

expect class NativeNativeThread

actual typealias NativeNativeThread = Long

typealias NativeNativeThread = Long

actual typealias NativeNativeThread = Thread

typealias NativeNativeThread = Thread

actual typealias NativeNativeThread = Long

typealias NativeNativeThread = Long

actual typealias NativeNativeThread = Long

typealias NativeNativeThread = Long

value class NativeThread(val native: NativeNativeThread)

NativeThreadDispatcher

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

NativeThreadPriority

inline class NativeThreadPriority(val ratio: Double)

class ThreadInfo(val name: String?, val code: () -> Unit)

Properties

val NativeNativeThread.pthread: CPointer<_opaque_pthread_t>?

val NativeNativeThread.pthread: ULong

Functions

__win32_threadStart

fun __win32_threadStart(value: COpaquePointer?): DWORD

fun nativeThread(isDaemon: Boolean = false, name: String? = null, priority: NativeThreadPriority = NativeThreadPriority.NORMAL, start: Boolean = true, block: (NativeThread) -> Unit): NativeThread

fun NativeThread.Companion.sleep(time: Duration)

fun NativeThread.Companion.sleep(time: FastDuration, exact: Boolean)

fun NativeThread.Companion.sleep(time: Duration, exact: Boolean)

fun NativeThread.Companion.sleepExact(time: FastDuration)

fun NativeThread.Companion.sleepExact(time: Duration)

fun NativeThread.Companion.sleepUntil(date: DateTime, exact: Boolean = true)

inline fun NativeThread.Companion.sleepWhile(stepTime: FastDuration = 1.0.fastMilliseconds, exact: Boolean = false, cond: () -> Boolean)

fun <T> NativeNativeThread.useHandle(block: (HANDLE?) -> T): T