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

LockFreeTaskQueueCore

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

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

Since

0.12.0

See also

LockFreeTaskQueue

Constructors

LockFreeTaskQueueCore

constructor(capacity: Int, singleConsumer: Boolean)

Types

internal object Companion

internal class Placeholder(val index: Int)

Properties

private val _next: AtomicReference<Core<E>?>

private val _state: AtomicReference<Long>

private val array: AtomicReferenceArray<Any?>

private val capacity: Int

val isEmpty: Boolean

private val mask: Int

private val singleConsumer: Boolean

Functions

fun addLast(element: E): Int

allocateNextCopy

private fun allocateNextCopy(state: Long): Core<E>

allocateOrGetNextCopy

private fun allocateOrGetNextCopy(state: Long): Core<E>

fun close(): Boolean

fillPlaceholder

private fun fillPlaceholder(index: Int, element: E): Core<E>?

fun isClosed(): Boolean

fun <R> map(transform: (E) -> R): List<R>

private fun markFrozen(): Long

fun next(): LockFreeTaskQueueCore<E>

removeFirstOrNull

fun removeFirstOrNull(): Any?

private fun removeSlowPath(oldHead: Int, newHead: Int): Core<E>?