Пакет kotlin.native.concurrent

Атомные значения и замораживание: атомные типы AtomicInt, AtomicLong, AtomicNativePtr и AtomicReference уникальны с точки зрения замораживания. А именно, они предоставляют операции изменения, но могут участвовать в замороженных подграфах. Таким образом, общие замороженные объекты могут иметь поля атомных типов.

class AtomicInt

Атомная ссылка на замороженный Kotlin-объект. Может использоваться в конкурентных сценариях, но часто должна быть типом с возможностью null и обнуляться, когда больше не требуется. В противном случае может произойти утечка памяти. Для обнаружения таких утечек в режиме отладки может быть полезно kotlin.native.internal.GC.detectCycles.

class AtomicReference<T>

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

class DetachedObjectGraph<T>

Атомная ссылка на Kotlin-объект. Может использоваться в конкурентных сценариях, но сначала должна быть заморожена, иначе ведет себя как обычная упаковка значения. Если заморожена, должна быть обнулена, когда больше не требуется. В противном случае может произойти утечка памяти. Для обнаружения таких утечек в режиме отладки может быть полезно kotlin.native.internal.GC.detectCycles.

class FreezableAtomicReference<T>

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

class FreezingException : RuntimeException

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

class Future<T>

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

enum class FutureState

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

class InvalidMutabilityException : RuntimeException

Изменяемый, одновременно доступный буфер данных. К нему могут одновременно обращаться несколько потоков.

class MutableData

Основы передачи объектов.

enum class TransferMode

Класс, представляющий worker.

class Worker

Общий указатель на Kotlin-объект, который не замораживает ссылаемый объект, когда сам замораживается.

class WorkerBoundReference<out T : Any>

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

annotation class SharedImmutable

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

annotation class ThreadLocal

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

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