Atomicfu delegated properties

Author: mvicsokolova

kotlinx-coroutines-core/api/kotlinx-coroutines-core.api

@@ -62,6 +62,7 @@ public class kotlinx/coroutines/CancellableContinuationImpl : kotlin/coroutines/
 	public fun getContinuationCancellationCause (Lkotlinx/coroutines/Job;)Ljava/lang/Throwable;
 	public final fun getResult ()Ljava/lang/Object;
 	public fun getStackTraceElement ()Ljava/lang/StackTraceElement;
+	public final fun getState$kotlinx_coroutines_core ()Ljava/lang/Object;
 	public fun initCancellability ()V
 	public fun invokeOnCancellation (Lkotlin/jvm/functions/Function1;)V
 	public fun isActive ()Z
@@ -433,6 +434,7 @@ public class kotlinx/coroutines/JobSupport : kotlinx/coroutines/ChildJob, kotlin
 	public final fun getCompletionExceptionOrNull ()Ljava/lang/Throwable;
 	public final fun getKey ()Lkotlin/coroutines/CoroutineContext$Key;
 	public final fun getOnJoin ()Lkotlinx/coroutines/selects/SelectClause0;
+	public final fun getParentHandle$kotlinx_coroutines_core ()Lkotlinx/coroutines/ChildHandle;
 	protected fun handleJobException (Ljava/lang/Throwable;)Z
 	protected final fun initParentJob (Lkotlinx/coroutines/Job;)V
 	public final fun invokeOnCompletion (Lkotlin/jvm/functions/Function1;)Lkotlinx/coroutines/DisposableHandle;
@@ -451,6 +453,7 @@ public class kotlinx/coroutines/JobSupport : kotlinx/coroutines/ChildJob, kotlin
 	public fun plus (Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;
 	public fun plus (Lkotlinx/coroutines/Job;)Lkotlinx/coroutines/Job;
 	public final fun registerSelectClause0 (Lkotlinx/coroutines/selects/SelectInstance;Lkotlin/jvm/functions/Function1;)V
+	public final fun setParentHandle$kotlinx_coroutines_core (Lkotlinx/coroutines/ChildHandle;)V
 	public final fun start ()Z
 	protected final fun toCancellationException (Ljava/lang/Throwable;Ljava/lang/String;)Ljava/util/concurrent/CancellationException;
 	public static synthetic fun toCancellationException$default (Lkotlinx/coroutines/JobSupport;Ljava/lang/Throwable;Ljava/lang/String;ILjava/lang/Object;)Ljava/util/concurrent/CancellationException;

kotlinx-coroutines-core/common/src/Await.kt

@@ -104,9 +104,7 @@ private class AwaitAll<T>(private val deferreds: Array<out Deferred<T>>) {
         lateinit var handle: DisposableHandle
 
         private val _disposer = atomic<DisposeHandlersOnCancel?>(null)
-        var disposer: DisposeHandlersOnCancel?
-            get() = _disposer.value
-            set(value) { _disposer.value = value }
+        var disposer: DisposeHandlersOnCancel? by _disposer
 
         override fun invoke(cause: Throwable?) {
             if (cause != null) {

kotlinx-coroutines-core/common/src/CancellableContinuationImpl.kt

@@ -74,7 +74,7 @@ internal open class CancellableContinuationImpl<in T>(
 
     private var parentHandle: DisposableHandle? = null
 
-    internal val state: Any? get() = _state.value
+    internal val state: Any? by _state
 
     public override val isActive: Boolean get() = state is NotCompleted
 

kotlinx-coroutines-core/common/src/CompletionState.kt

@@ -44,7 +44,7 @@ internal open class CompletedExceptionally(
     handled: Boolean = false
 ) {
     private val _handled = atomic(handled)
-    val handled: Boolean get() = _handled.value
+    val handled: Boolean by _handled
     fun makeHandled(): Boolean = _handled.compareAndSet(false, true)
     override fun toString(): String = "$classSimpleName[$cause]"
 }

kotlinx-coroutines-core/common/src/EventLoop.common.kt

@@ -189,9 +189,7 @@ internal abstract class EventLoopImplBase: EventLoopImplPlatform(), Delay {
     private val _delayed = atomic<DelayedTaskQueue?>(null)
 
     private val _isCompleted = atomic(false)
-    private var isCompleted
-        get() = _isCompleted.value
-        set(value) { _isCompleted.value = value }
+    private var isCompleted: Boolean by _isCompleted
 
     override val isEmpty: Boolean get() {
         if (!isUnconfinedQueueEmpty) return false

kotlinx-coroutines-core/common/src/JobSupport.kt

@@ -129,9 +129,7 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
     private val _state = atomic<Any?>(if (active) EMPTY_ACTIVE else EMPTY_NEW)
 
     private val _parentHandle = atomic<ChildHandle?>(null)
-    internal var parentHandle: ChildHandle?
-        get() = _parentHandle.value
-        set(value) { _parentHandle.value = value }
+    internal var parentHandle: ChildHandle? by _parentHandle
 
     // ------------ initialization ------------
 
@@ -1077,19 +1075,13 @@ public open class JobSupport constructor(active: Boolean) : Job, ChildJob, Paren
         rootCause: Throwable?
     ) : SynchronizedObject(), Incomplete {
         private val _isCompleting = atomic(isCompleting)
-        var isCompleting: Boolean
-            get() = _isCompleting.value
-            set(value) { _isCompleting.value = value }
+        var isCompleting: Boolean by _isCompleting
 
         private val _rootCause = atomic(rootCause)
-        var rootCause: Throwable? // NOTE: rootCause is kept even when SEALED
-            get() = _rootCause.value
-            set(value) { _rootCause.value = value }
+        var rootCause: Throwable? by _rootCause // NOTE: rootCause is kept even when SEALED
 
         private val _exceptionsHolder = atomic<Any?>(null)
-        private var exceptionsHolder: Any? // Contains null | Throwable | ArrayList | SEALED
-            get() = _exceptionsHolder.value
-            set(value) { _exceptionsHolder.value = value }
+        private var exceptionsHolder: Any? by _exceptionsHolder // Contains null | Throwable | ArrayList | SEALED
 
         // Note: cannot be modified when sealed
         val isSealed: Boolean get() = exceptionsHolder === SEALED

kotlinx-coroutines-core/common/src/channels/ArrayBroadcastChannel.kt

@@ -51,19 +51,13 @@ internal class ArrayBroadcastChannel<E>(
     // head, tail, and size are guarded by bufferLock
 
     private val _head = atomic(0L)
-    private var head: Long // do modulo on use of head
-        get() = _head.value
-        set(value) { _head.value = value }
+    private var head: Long by _head // do modulo on use of head
 
     private val _tail = atomic(0L)
-    private var tail: Long // do modulo on use of tail
-        get() = _tail.value
-        set(value) { _tail.value = value }
+    private var tail: Long by _tail // do modulo on use of tail
 
     private val _size = atomic(0)
-    private var size: Int
-        get() = _size.value
-        set(value) { _size.value = value }
+    private var size: Int by _size
 
     @Suppress("DEPRECATION")
     private val subscribers = subscriberList<Subscriber<E>>()
@@ -217,9 +211,7 @@ internal class ArrayBroadcastChannel<E>(
         private val subLock = ReentrantLock()
 
         private val _subHead = atomic(0L)
-        var subHead: Long // guarded by subLock
-            get() = _subHead.value
-            set(value) { _subHead.value = value }
+        var subHead: Long by _subHead // guarded by subLock
 
         override val isBufferAlwaysEmpty: Boolean get() = false
         override val isBufferEmpty: Boolean get() = subHead >= broadcastChannel.tail

kotlinx-coroutines-core/common/src/internal/Atomic.kt

@@ -58,7 +58,7 @@ public abstract class AtomicOp<in T> : OpDescriptor() {
     private val _consensus = atomic<Any?>(NO_DECISION)
 
     // Returns NO_DECISION when there is not decision yet
-    val consensus: Any? get() = _consensus.value
+    val consensus: Any? by _consensus
 
     val isDecided: Boolean get() = _consensus.value !== NO_DECISION
 

kotlinx-coroutines-core/common/src/internal/ConcurrentLinkedList.kt

@@ -96,7 +96,7 @@ internal abstract class ConcurrentLinkedListNode<N : ConcurrentLinkedListNode<N>
     // Pointer to the previous node, updates in [remove] function.
     private val _prev = atomic(prev)
 
-    private val nextOrClosed get() = _next.value
+    private val nextOrClosed: Any? by _next
 
     /**
      * Returns the next segment or `null` of the one does not exist,
@@ -123,7 +123,7 @@ internal abstract class ConcurrentLinkedListNode<N : ConcurrentLinkedListNode<N>
      */
     val isTail: Boolean get() = next == null
 
-    val prev: N? get() = _prev.value
+    val prev: N? by _prev
 
     /**
      * Cleans the pointer to the previous node.

kotlinx-coroutines-core/common/src/selects/Select.kt

@@ -250,9 +250,7 @@ internal class SelectBuilderImpl<in R>(
 
     // cancellability support
     private val _parentHandle = atomic<DisposableHandle?>(null)
-    private var parentHandle: DisposableHandle?
-        get() = _parentHandle.value
-        set(value) { _parentHandle.value = value }
+    private var parentHandle: DisposableHandle? by _parentHandle
 
     /* Result state machine
 

kotlinx-coroutines-core/common/test/channels/ChannelUndeliveredElementTest.kt

@@ -116,8 +116,7 @@ class ChannelUndeliveredElementTest : TestBase() {
     private class Resource(val value: String) {
         private val _cancelled = atomic(false)
 
-        val isCancelled: Boolean
-            get() = _cancelled.value
+        val isCancelled: Boolean by _cancelled
 
         fun cancel() {
             check(!_cancelled.getAndSet(true)) { "Already cancelled" }

kotlinx-coroutines-core/concurrent/src/internal/LockFreeLinkedList.kt

@@ -325,7 +325,7 @@ public actual open class LockFreeLinkedListNode {
             queue.correctPrev(op) // queue head is never removed, so null result can only mean RETRY_ATOMIC
 
         private val _affectedNode = atomic<Node?>(null)
-        final override val affectedNode: Node? get() = _affectedNode.value
+        final override val affectedNode: Node? by _affectedNode
         final override val originalNext: Node get() = queue
 
         override fun retry(affected: Node, next: Any): Boolean = next !== queue
@@ -371,8 +371,8 @@ public actual open class LockFreeLinkedListNode {
             }
         }
 
-        final override val affectedNode: Node? get() = _affectedNode.value
-        final override val originalNext: Node? get() = _originalNext.value
+        final override val affectedNode: Node? by _affectedNode
+        final override val originalNext: Node? by _originalNext
 
         // check node predicates here, must signal failure if affect is not of type T
         protected override fun failure(affected: Node): Any? =

kotlinx-coroutines-core/jvm/src/debug/internal/ConcurrentWeakMap.kt

@@ -23,8 +23,7 @@ internal class ConcurrentWeakMap<K : Any, V: Any>(
     private val core = atomic(Core(MIN_CAPACITY))
     private val weakRefQueue: ReferenceQueue<K>? = if (weakRefQueue) ReferenceQueue() else null
 
-    override val size: Int
-        get() = _size.value
+    override val size: Int by _size
 
     private fun decrementSize() { _size.decrementAndGet() }
 

kotlinx-coroutines-core/jvm/src/scheduling/CoroutineScheduler.kt

@@ -295,7 +295,7 @@ internal class CoroutineScheduler(
 
     // This is used a "stop signal" for close and shutdown functions
     private val _isTerminated = atomic(false)
-    val isTerminated: Boolean get() = _isTerminated.value
+    val isTerminated: Boolean by _isTerminated
 
     companion object {
         // A symbol to mark workers that are not in parkedWorkersStack