Объявления уровня пакета

kotlin-stdlib/kotlin.concurrent

Низкоуровневые строительные блоки и вспомогательные функции для параллельного программирования.

Типы

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
class AtomicArray<T>

Array, элементы которого всегда обновляются атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicInt

Платформы и требования к версиям: Native (1.9)

class AtomicInt(var value: Int)

Значение Int, которое всегда обновляется атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicIntArray

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
class AtomicIntArray

IntArray, элементы которого всегда обновляются атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicLong

Платформы и требования к версиям: Native (1.9)

class AtomicLong(var value: Long)

Значение Long, которое всегда обновляется атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicLongArray

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
class AtomicLongArray

LongArray, элементы которого всегда обновляются атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicNativePtr

Платформы и требования к версиям: Native (1.9)

class AtomicNativePtr(var value: NativePtr)

Значение kotlinx.cinterop.NativePtr, которое всегда обновляется атомарно. Дополнительные сведения о гарантиях атомарности при чтении и записи см. в kotlin.concurrent.Volatile.

AtomicReference

Платформы и требования к версиям: Native (1.9)

class AtomicReference<T>(var value: T)

Ссылка на объект, которая всегда обновляется атомарно.

Volatile

Платформы и требования к версиям: Common (1.9), Native (1.9)


@Target(allowedTargets = [AnnotationTarget.FIELD])
expect annotation class Volatile

Помечает резервное поле аннотированного свойства var как volatile, то есть чтение и запись этого поля выполняются атомарно, а результаты записи всегда становятся видны другим потокам. Если другой поток считывает значение этого поля (например, через его метод доступа), он видит не только это значение, но и все побочные эффекты, приведшие к его записи.

Платформы и требования к версиям: JVM (1.9)

actual typealias Volatile = kotlin.jvm.Volatile

typealias Volatile = kotlin.jvm.Volatile

Помечает резервное поле JVM аннотированного свойства var как volatile, то есть чтение и запись этого поля выполняются атомарно, а результаты записи всегда становятся видны другим потокам. Если другой поток считывает значение этого поля (например, через его метод доступа), он видит не только это значение, но и все побочные эффекты, приведшие к его записи.

Функции

AtomicArray

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
inline fun <T> AtomicArray(size: Int, init: (Int) -> T): AtomicArray<T>

Создает новый AtomicArray заданного size, инициализируя каждый элемент вызовом заданной функции init.

AtomicIntArray

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
inline fun AtomicIntArray(size: Int, init: (Int) -> Int): AtomicIntArray

Создает новый AtomicIntArray заданного size, инициализируя каждый элемент вызовом заданной функции init.

AtomicLongArray

Платформы и требования к версиям: Native (1.9)


@ExperimentalStdlibApi
inline fun AtomicLongArray(size: Int, init: (Int) -> Long): AtomicLongArray

Создает новый AtomicLongArray заданного size, инициализируя каждый элемент вызовом заданной функции init.

fixedRateTimer

Платформы и требования к версиям: JVM (1.0)

inline fun fixedRateTimer(name: String? = null, daemon: Boolean = false, startAt: Date, period: Long, crossinline action: TimerTask.() -> Unit): Timer

Создает таймер, который периодически выполняет указанное action, начиная с указанной даты startAt и с интервалом period миллисекунд между началом предыдущей задачи и началом следующей.

inline fun fixedRateTimer(name: String? = null, daemon: Boolean = false, initialDelay: Long = 0.toLong(), period: Long, crossinline action: TimerTask.() -> Unit): Timer

Создает таймер, который периодически выполняет указанное action, начиная через указанный initialDelay (в миллисекундах) и с интервалом period миллисекунд между началом предыдущей задачи и началом следующей.

getOrSet

Платформы и требования к версиям: JVM (1.0)

inline fun <T : Any> ThreadLocal<T>.getOrSet(default: () -> T): T

Возвращает значение из копии этой поток-локальной переменной для текущего потока или заменяет его результатом вызова функции default, если это значение было null.

read

Платформы и требования к версиям: JVM (1.0)


@IgnorableReturnValue
inline fun <T> ReentrantReadWriteLock.read(action: () -> T): T

Выполняет указанное action под блокировкой чтения этой блокировки.

schedule

Платформы и требования к версиям: JVM (1.0)

inline fun Timer.schedule(time: Date, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует выполнение action в указанное time.

inline fun Timer.schedule(delay: Long, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует выполнение action по истечении указанной delay (в миллисекундах).

inline fun Timer.schedule(time: Date, period: Long, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует периодическое выполнение action, начиная с указанного time и с интервалом period миллисекунд между окончанием предыдущей задачи и началом следующей.

inline fun Timer.schedule(delay: Long, period: Long, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует периодическое выполнение action, начиная по истечении указанной delay (в миллисекундах) и с интервалом period миллисекунд между окончанием предыдущей задачи и началом следующей.

scheduleAtFixedRate

Платформы и требования к версиям: JVM (1.0)

inline fun Timer.scheduleAtFixedRate(time: Date, period: Long, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует периодическое выполнение action, начиная с указанного time и с интервалом period миллисекунд между началом предыдущей задачи и началом следующей.

inline fun Timer.scheduleAtFixedRate(delay: Long, period: Long, crossinline action: TimerTask.() -> Unit): TimerTask

Планирует периодическое выполнение action, начиная по истечении указанной delay (в миллисекундах) и с интервалом period миллисекунд между началом предыдущей задачи и началом следующей.

thread

Платформы и требования к версиям: JVM (1.0)

fun thread(start: Boolean = true, isDaemon: Boolean = false, contextClassLoader: ClassLoader? = null, name: String? = null, priority: Int = -1, block: () -> Unit): Thread

Создает поток, выполняющий указанный блок кода block.

timer

Платформы и требования к версиям: JVM (1.0)

inline fun timer(name: String? = null, daemon: Boolean = false, startAt: Date, period: Long, crossinline action: TimerTask.() -> Unit): Timer

Создает таймер, который периодически выполняет указанное action, начиная с указанной даты startAt и с интервалом period миллисекунд между окончанием предыдущей задачи и началом следующей.

inline fun timer(name: String? = null, daemon: Boolean = false, initialDelay: Long = 0.toLong(), period: Long, crossinline action: TimerTask.() -> Unit): Timer

Создает таймер, который периодически выполняет указанное action, начиная через указанный initialDelay (в миллисекундах) и с интервалом period миллисекунд между окончанием предыдущей задачи и началом следующей.

timerTask

Платформы и требования к версиям: JVM (1.0)

inline fun timerTask(crossinline action: TimerTask.() -> Unit): TimerTask

Оборачивает указанное action в TimerTask.

withLock

Платформы и требования к версиям: JVM (1.0)


@IgnorableReturnValue
inline fun <T> Lock.withLock(action: () -> T): T

Выполняет указанное action под этой блокировкой.

write

Платформы и требования к версиям: JVM (1.0)


@IgnorableReturnValue
inline fun <T> ReentrantReadWriteLock.write(action: () -> T): T

Выполняет указанное action под блокировкой записи этой блокировки.

© 2010–2026 JetBrains s.r.o. and Kotlin Programming Language contributors
Licensed under the Apache License, Version 2.0.
https://kotlinlang.org/api/core/kotlin-stdlib/kotlin.concurrent/index.html