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

Package-level declarations

Types

private typealias Core<E> = LockFreeTaskQueueCore<E>

CoroutineScopeModule

@Module

object CoroutineScopeModule

DispatcherProviderComponent

interface DispatcherProviderComponent

LimitedDispatcherImpl

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

Forked from kotlinx.coroutines

LockFreeTaskQueue

internal open class LockFreeTaskQueue<E : Any>(singleConsumer: Boolean)

Lock-free Multiply-Producer xxx-Consumer Queue for task scheduling purposes.

LockFreeTaskQueueCore

internal class LockFreeTaskQueueCore<E : Any>(val capacity: Int, val singleConsumer: Boolean)

Lock-free Multiply-Producer xxx-Consumer Queue core.

ModuleCheckDispatcherProvider

class ModuleCheckDispatcherProvider @Inject constructor(limitedDispatcher: LimitedDispatcher) : DispatcherProvider

Uses a LimitedDispatcher as the default in order to keep things "fair" and limit heap size.

Functions

checkParallelism

internal fun Int.checkParallelism()

internal inline fun <T> AtomicReference<T>.loop(action: (T) -> Unit): Nothing

internal inline fun <T> AtomicReference<T>.update(function: (T) -> T)