Skip to content

Commit 80503c4

Browse files
serrasserras
committed
Update the rest
1 parent b3cd39c commit 80503c4

File tree

12 files changed

+214
-121
lines changed

12 files changed

+214
-121
lines changed

‎arrow-libs/core/arrow-atomic/api/android/arrow-atomic.api

+57-27
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,11 @@
1+
public final class arrow/atomic/Atomic {
2+
public fun <init> (Ljava/lang/Object;)V
3+
public final fun compareAndSet (Ljava/lang/Object;Ljava/lang/Object;)Z
4+
public final fun get ()Ljava/lang/Object;
5+
public final fun getAndSet (Ljava/lang/Object;)Ljava/lang/Object;
6+
public final fun set (Ljava/lang/Object;)V
7+
}
8+
19
public final class arrow/atomic/AtomicBoolean {
210
public fun <init> (Z)V
311
public final fun compareAndSet (ZZ)Z
@@ -18,39 +26,61 @@ public final class arrow/atomic/AtomicBooleanKt {
1826
public static final fun updateAndGet (Larrow/atomic/AtomicBoolean;Lkotlin/jvm/functions/Function1;)Z
1927
}
2028

29+
public final class arrow/atomic/AtomicInt {
30+
public fun <init> (I)V
31+
public final fun addAndGet (I)I
32+
public final fun compareAndSet (II)Z
33+
public final fun decrementAndGet ()I
34+
public final fun get ()I
35+
public final fun getAndSet (I)I
36+
public final fun incrementAndGet ()I
37+
public final fun set (I)V
38+
}
39+
2140
public final class arrow/atomic/AtomicIntKt {
22-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)I
23-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicInteger;)I
24-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
25-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicInteger;I)V
26-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)Z
27-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
28-
public static final fun update (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)V
29-
public static final fun update (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
30-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)I
41+
public static final fun getAndUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)I
42+
public static final fun getValue (Larrow/atomic/AtomicInt;)I
43+
public static final fun loop (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
44+
public static final fun setValue (Larrow/atomic/AtomicInt;I)V
45+
public static final fun tryUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)Z
46+
public static final fun tryUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
47+
public static final fun update (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)V
48+
public static final fun update (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
49+
public static final fun updateAndGet (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)I
3150
}
3251

3352
public final class arrow/atomic/AtomicKt {
34-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
35-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Object;
36-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
37-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Object;)V
38-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Z
39-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
40-
public static final fun update (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)V
41-
public static final fun update (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
42-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
53+
public static final fun getAndUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
54+
public static final fun getValue (Larrow/atomic/Atomic;)Ljava/lang/Object;
55+
public static final fun loop (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
56+
public static final fun setValue (Larrow/atomic/Atomic;Ljava/lang/Object;)V
57+
public static final fun tryUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Z
58+
public static final fun tryUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
59+
public static final fun update (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)V
60+
public static final fun update (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
61+
public static final fun updateAndGet (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
62+
}
63+
64+
public final class arrow/atomic/AtomicLong {
65+
public fun <init> (J)V
66+
public final fun addAndGet (J)J
67+
public final fun compareAndSet (JJ)Z
68+
public final fun decrementAndGet ()J
69+
public final fun get ()J
70+
public final fun getAndSet (J)J
71+
public final fun incrementAndGet ()J
72+
public final fun set (J)V
4373
}
4474

4575
public final class arrow/atomic/AtomicLongKt {
46-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
47-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicLong;)J
48-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
49-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicLong;J)V
50-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Z
51-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
52-
public static final fun update (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)V
53-
public static final fun update (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
54-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
76+
public static final fun getAndUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
77+
public static final fun getValue (Larrow/atomic/AtomicLong;)J
78+
public static final fun loop (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
79+
public static final fun setValue (Larrow/atomic/AtomicLong;J)V
80+
public static final fun tryUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Z
81+
public static final fun tryUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
82+
public static final fun update (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)V
83+
public static final fun update (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
84+
public static final fun updateAndGet (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
5585
}
5686

‎arrow-libs/core/arrow-atomic/api/jvm/arrow-atomic.api

+57-27
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,11 @@
1+
public final class arrow/atomic/Atomic {
2+
public fun <init> (Ljava/lang/Object;)V
3+
public final fun compareAndSet (Ljava/lang/Object;Ljava/lang/Object;)Z
4+
public final fun get ()Ljava/lang/Object;
5+
public final fun getAndSet (Ljava/lang/Object;)Ljava/lang/Object;
6+
public final fun set (Ljava/lang/Object;)V
7+
}
8+
19
public final class arrow/atomic/AtomicBoolean {
210
public fun <init> (Z)V
311
public final fun compareAndSet (ZZ)Z
@@ -18,39 +26,61 @@ public final class arrow/atomic/AtomicBooleanKt {
1826
public static final fun updateAndGet (Larrow/atomic/AtomicBoolean;Lkotlin/jvm/functions/Function1;)Z
1927
}
2028

29+
public final class arrow/atomic/AtomicInt {
30+
public fun <init> (I)V
31+
public final fun addAndGet (I)I
32+
public final fun compareAndSet (II)Z
33+
public final fun decrementAndGet ()I
34+
public final fun get ()I
35+
public final fun getAndSet (I)I
36+
public final fun incrementAndGet ()I
37+
public final fun set (I)V
38+
}
39+
2140
public final class arrow/atomic/AtomicIntKt {
22-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)I
23-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicInteger;)I
24-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
25-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicInteger;I)V
26-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)Z
27-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
28-
public static final fun update (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)V
29-
public static final fun update (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
30-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicInteger;Lkotlin/jvm/functions/Function1;)I
41+
public static final fun getAndUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)I
42+
public static final fun getValue (Larrow/atomic/AtomicInt;)I
43+
public static final fun loop (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
44+
public static final fun setValue (Larrow/atomic/AtomicInt;I)V
45+
public static final fun tryUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)Z
46+
public static final fun tryUpdate (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
47+
public static final fun update (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)V
48+
public static final fun update (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
49+
public static final fun updateAndGet (Larrow/atomic/AtomicInt;Lkotlin/jvm/functions/Function1;)I
3150
}
3251

3352
public final class arrow/atomic/AtomicKt {
34-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
35-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicReference;)Ljava/lang/Object;
36-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
37-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/Object;)V
38-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Z
39-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
40-
public static final fun update (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)V
41-
public static final fun update (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
42-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicReference;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
53+
public static final fun getAndUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
54+
public static final fun getValue (Larrow/atomic/Atomic;)Ljava/lang/Object;
55+
public static final fun loop (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
56+
public static final fun setValue (Larrow/atomic/Atomic;Ljava/lang/Object;)V
57+
public static final fun tryUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Z
58+
public static final fun tryUpdate (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
59+
public static final fun update (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)V
60+
public static final fun update (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
61+
public static final fun updateAndGet (Larrow/atomic/Atomic;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;
62+
}
63+
64+
public final class arrow/atomic/AtomicLong {
65+
public fun <init> (J)V
66+
public final fun addAndGet (J)J
67+
public final fun compareAndSet (JJ)Z
68+
public final fun decrementAndGet ()J
69+
public final fun get ()J
70+
public final fun getAndSet (J)J
71+
public final fun incrementAndGet ()J
72+
public final fun set (J)V
4373
}
4474

4575
public final class arrow/atomic/AtomicLongKt {
46-
public static final fun getAndUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
47-
public static final fun getValue (Ljava/util/concurrent/atomic/AtomicLong;)J
48-
public static final fun loop (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
49-
public static final fun setValue (Ljava/util/concurrent/atomic/AtomicLong;J)V
50-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Z
51-
public static final fun tryUpdate (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
52-
public static final fun update (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)V
53-
public static final fun update (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
54-
public static final fun updateAndGet (Ljava/util/concurrent/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
76+
public static final fun getAndUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
77+
public static final fun getValue (Larrow/atomic/AtomicLong;)J
78+
public static final fun loop (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
79+
public static final fun setValue (Larrow/atomic/AtomicLong;J)V
80+
public static final fun tryUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)Z
81+
public static final fun tryUpdate (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Z
82+
public static final fun update (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)V
83+
public static final fun update (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;Lkotlin/jvm/functions/Function2;)Ljava/lang/Object;
84+
public static final fun updateAndGet (Larrow/atomic/AtomicLong;Lkotlin/jvm/functions/Function1;)J
5585
}
5686

‎arrow-libs/core/arrow-autoclose/src/jvmTest/kotlin/arrow/AutoCloseJvmTest.kt

+7-4
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,17 @@
1+
@file:OptIn(ExperimentalAtomicApi::class)
2+
13
package arrow
24

3-
import arrow.atomic.AtomicBoolean
45
import io.kotest.assertions.throwables.shouldThrow
56
import io.kotest.matchers.shouldBe
67
import kotlinx.coroutines.test.runTest
8+
import kotlin.concurrent.atomics.AtomicBoolean
9+
import kotlin.concurrent.atomics.ExperimentalAtomicApi
710
import kotlin.test.Test
811

912
class AutoCloseJvmTest {
1013

11-
@Test
14+
@Test @Suppress("ASSIGNED_VALUE_IS_NEVER_READ")
1215
fun blowTheAutoScopeOnFatal() = runTest {
1316
var wasActive = false
1417
val res = Resource()
@@ -49,10 +52,10 @@ class AutoCloseJvmTest {
4952
private class Resource : AutoCloseable {
5053
private val isActive = AtomicBoolean(true)
5154

52-
fun isActive(): Boolean = isActive.get()
55+
fun isActive(): Boolean = isActive.load()
5356

5457
fun shutdown() {
55-
require(isActive.compareAndSet(expected = true, new = false)) {
58+
require(isActive.compareAndSet(expectedValue = true, newValue = false)) {
5659
"Already shut down"
5760
}
5861
}

‎arrow-libs/core/arrow-core/api/arrow-core.klib.api

+2-2
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ final class <#A: in kotlin/Any?> arrow.core.raise/SingletonRaise : arrow.core.ra
8181
}
8282

8383
final class <#A: kotlin/Any?> arrow.core.raise/IorRaise : arrow.core.raise/Raise<#A> { // arrow.core.raise/IorRaise|null[0]
84-
constructor <init>(kotlin/Function2<#A, #A, #A>, arrow.atomic/Atomic<kotlin/Any?>, arrow.core.raise/Raise<#A>) // arrow.core.raise/IorRaise.<init>|<init>(kotlin.Function2<1:0,1:0,1:0>;arrow.atomic.Atomic<kotlin.Any?>;arrow.core.raise.Raise<1:0>){}[0]
84+
constructor <init>(kotlin/Function2<#A, #A, #A>, kotlin.concurrent.atomics/AtomicReference<kotlin/Any?>, arrow.core.raise/Raise<#A>) // arrow.core.raise/IorRaise.<init>|<init>(kotlin.Function2<1:0,1:0,1:0>;kotlin.concurrent.atomics.AtomicReference<kotlin.Any?>;arrow.core.raise.Raise<1:0>){}[0]
8585

8686
final val combineError // arrow.core.raise/IorRaise.combineError|{}combineError[0]
8787
final fun <get-combineError>(): kotlin/Function2<#A, #A, #A> // arrow.core.raise/IorRaise.combineError.<get-combineError>|<get-combineError>(){}[0]
@@ -343,7 +343,7 @@ final class arrow.core.raise/ResultRaise : arrow.core.raise/Raise<kotlin/Throwab
343343
}
344344

345345
final value class <#A: kotlin/Any?, #B: kotlin/Any?> arrow.core/AtomicMemoizationCache : arrow.core/MemoizationCache<#A, #B> { // arrow.core/AtomicMemoizationCache|null[0]
346-
constructor <init>(arrow.atomic/Atomic<kotlin.collections/Map<#A, #B>> = ...) // arrow.core/AtomicMemoizationCache.<init>|<init>(arrow.atomic.Atomic<kotlin.collections.Map<1:0,1:1>>){}[0]
346+
constructor <init>(kotlin.concurrent.atomics/AtomicReference<kotlin.collections/Map<#A, #B>> = ...) // arrow.core/AtomicMemoizationCache.<init>|<init>(kotlin.concurrent.atomics.AtomicReference<kotlin.collections.Map<1:0,1:1>>){}[0]
347347

348348
final fun equals(kotlin/Any?): kotlin/Boolean // arrow.core/AtomicMemoizationCache.equals|equals(kotlin.Any?){}[0]
349349
final fun get(#A): #B? // arrow.core/AtomicMemoizationCache.get|get(1:0){}[0]

‎arrow-libs/fx/arrow-collectors/src/commonMain/kotlin/arrow/collectors/AtomicUtils.kt

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
@file:OptIn(ExperimentalAtomicApi::class)
2+
3+
package arrow.collectors
4+
5+
import kotlin.concurrent.atomics.AtomicInt
6+
import kotlin.concurrent.atomics.AtomicReference
7+
import kotlin.concurrent.atomics.ExperimentalAtomicApi
8+
9+
internal inline fun AtomicInt.update(block: (Int) -> Int) {
10+
while (true) {
11+
val old = load()
12+
val new = block(old)
13+
if (compareAndSet(old, new)) return
14+
}
15+
}
16+
17+
internal inline fun <T> AtomicReference<T>.update(block: (T) -> T) {
18+
while (true) {
19+
val old = load()
20+
val new = block(old)
21+
if (compareAndSet(old, new)) return
22+
}
23+
}

‎arrow-libs/fx/arrow-collectors/src/commonMain/kotlin/arrow/collectors/Collectors.kt

-16
Original file line numberDiff line numberDiff line change
@@ -138,19 +138,3 @@ public object Collectors {
138138
characteristics = Characteristics.IDENTITY_UNORDERED
139139
)
140140
}
141-
142-
internal inline fun AtomicInt.update(block: (Int) -> Int) {
143-
while (true) {
144-
val old = load()
145-
val new = block(old)
146-
if (compareAndSet(old, new)) return
147-
}
148-
}
149-
150-
internal inline fun <T> AtomicReference<T>.update(block: (T) -> T) {
151-
while (true) {
152-
val old = load()
153-
val new = block(old)
154-
if (compareAndSet(old, new)) return
155-
}
156-
}

0 commit comments

Comments
 (0)