Пакет kotlin.native.concurrent

Обёртка над Int с атомными синхронизированными операциями.

class AtomicInt

Обёртка над Long с атомными синхронизированными операциями.

class AtomicLong

Обёртка над kotlinx.cinterop.NativePtr с атомными синхронизированными операциями.

class AtomicNativePtr

Обёртка над Kotlin-объектом с атомными операциями.

class AtomicReference<T>

Откреплённый граф объектов инкапсулирует передаваемый откреплённый подграф, к которому нельзя получить доступ извне, пока он не будет прикреплён с помощью расширяющегося функционального метода attach.

class DetachedObjectGraph<T>

Примечание: этот класс полезен только с устаревшей системой управления памятью. Используйте AtomicReference вместо него.

class FreezableAtomicReference<T>

Исключение, выбрасываемое всякий раз, когда заморозка недоступна.

class FreezingException : RuntimeException

Состояние объекта Future.

enum class FutureState

Исключение, выбрасываемое при попытке изменить замороженные объекты.

class InvalidMutabilityException : RuntimeException

Буфер данных, доступный для многопоточной модификации. Может одновременно использоваться несколькими рабочими процессами.

class MutableData

Примечание: современная система управления памятью Kotlin/Native позволяет обмениваться объектами между потоками без дополнительных церемоний, поэтому TransferMode имеет эффект только в устаревшей системе управления памятью.

enum class TransferMode

Управляемая ссылка на Kotlin-объект, которая не замораживает сославшийся объект при собственном замораживании.

class WorkerBoundReference<out T : Any>

Примечание: эта аннотация имеет эффект только в Kotlin/Native с устаревшей системой управления памятью.

annotation class SharedImmutable

Помечает глобальную переменную или объект как локальную для потока. Объект остается изменяемым, и его состояние можно менять, но каждый поток будет иметь отдельную копию этого объекта, поэтому изменения в одном потоке не отражаются в другом.

annotation class ThreadLocal

Проверяет, является ли данный объект нулевым, замороженным или постоянным (т.е. созданным во время компиляции).

val Any?.isFrozen: Boolean

Атомарный ленивый инициализатор, может использоваться в замороженных объектах, замораживает лямбду инициализации, поэтому используйте с осторожностью. Кроме того, как и при других использованиях AtomicReference, потенциально может привести к утечке памяти, поэтому рекомендуется использовать atomicLazy в случаях объектов, живущих вечно, таких как объекты-синглтоны, или в случаях, когда гарантируется отсутствие циклического мусора.

fun <T> atomicLazy(initializer: () -> T): Lazy<T>

Прикрепляет ранее отсоединённую подграф объекта, созданную с помощью DetachedObjectGraph. Обратите внимание, что после прикрепления графа объектов указатель DetachedObjectGraph.stable больше не имеет смысла и должен быть удалён, поэтому прикрепление одного объекта DetachedObjectGraph может произойти только один раз.

fun <T> DetachedObjectGraph<T>.attach(): T

Эта функция гарантирует, что если во время попытки заморозки мы видим такой объект — попытка заморозки завершается неудачно, и выбрасывается FreezingException.

fun Any.ensureNeverFrozen()

Замораживает подграф объекта, доступный из этого объекта. Замороженные объекты могут свободно использоваться между потоками/рабочими процессами.

fun <T> T.freeze(): T

Выполняет block с новой рабочей единицей как ресурсом, запуская новую рабочую единицу, вызывая предоставленный block (в текущем контексте) с только что запущенной рабочей единицей как этой и завершая рабочую единицу после завершения блока. Обратите внимание, что эта операция довольно ресурсоёмкая, используйте предварительно настроенную рабочую единицу или пул рабочих единиц, если вам нужно выполнять её часто.

fun <R> withWorker(
    name: String? = null, 
    errorReporting: Boolean = true, 
    block: Worker.() -> R
): R