Add optins required in Kotlin 1.9

benchmarks/src/jmh/kotlin/benchmarks/scheduler/ForkJoinBenchmark.kt

@@ -110,8 +110,13 @@ open class ForkJoinBenchmark : ParametrizedDispatcherBase() {
         }
     }
 
-    class RecursiveAction(val coefficients: LongArray, val start: Int, val end: Int, @Volatile var result: Double = 0.0,
-                          parent: RecursiveAction? = null) : CountedCompleter<Double>(parent) {
+    class RecursiveAction(
+        val coefficients: LongArray,
+        val start: Int,
+        val end: Int,
+        @Volatile @OptIn(ExperimentalStdlibApi::class) var result: Double = 0.0,
+        parent: RecursiveAction? = null
+    ) : CountedCompleter<Double>(parent) {
 
         private var first: ForkJoinTask<Double>? = null
         private var second: ForkJoinTask<Double>? = null

benchmarks/src/jmh/kotlin/benchmarks/scheduler/StatefulAwaitsBenchmark.kt

@@ -57,6 +57,7 @@ open class StatefulAsyncBenchmark : ParametrizedDispatcherBase() {
     override var dispatcher: String = "fjp"
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var state: Array<LongArray>? = null
 
     @Setup

benchmarks/src/jmh/kotlin/benchmarks/tailcall/SimpleChannelBenchmark.kt

@@ -19,6 +19,7 @@ open class SimpleChannelBenchmark {
     private val iterations = 10_000
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var sink: Int = 0
 
     @Benchmark

docs/topics/shared-mutable-state-and-concurrency.md

@@ -106,7 +106,8 @@ suspend fun massiveRun(action: suspend () -> Unit) {
 }
 
 //sampleStart
-@Volatile // in Kotlin `volatile` is an annotation 
+@OptIn(ExperimentalStdlibApi::class)
+@Volatile // in Kotlin `volatile` is an annotation
 var counter = 0
 
 fun main() = runBlocking {

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

@@ -412,6 +412,7 @@ internal abstract class EventLoopImplBase: EventLoopImplPlatform(), Delay {
         @JvmField var nanoTime: Long
     ) : Runnable, Comparable<DelayedTask>, DisposableHandle, ThreadSafeHeapNode, SynchronizedObject() {
         @Volatile
+        @OptIn(ExperimentalStdlibApi::class)
         private var _heap: Any? = null // null | ThreadSafeHeap | DISPOSED_TASK
 
         override var heap: ThreadSafeHeap<*>?

kotlinx-coroutines-core/jdk8/src/future/Future.kt

@@ -180,7 +180,7 @@ public suspend fun <T> CompletionStage<T>.await(): T {
 }
 
 private class ContinuationHandler<T>(
-    @Volatile @JvmField var cont: Continuation<T>?
+    @Volatile @OptIn(ExperimentalStdlibApi::class) @JvmField var cont: Continuation<T>?
 ) : BiFunction<T?, Throwable?, Unit> {
     @Suppress("UNCHECKED_CAST")
     override fun apply(result: T?, exception: Throwable?) {

kotlinx-coroutines-core/jvm/src/CoroutineContext.kt

@@ -213,6 +213,7 @@ internal actual class UndispatchedCoroutine<in T>actual constructor (
      * in another.
      */
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var threadLocalIsSet = false
 
     init {

kotlinx-coroutines-core/jvm/src/DefaultExecutor.kt

@@ -43,6 +43,7 @@ internal actual object DefaultExecutor : EventLoopImplBase(), Runnable {
 
     @Suppress("ObjectPropertyName")
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var _thread: Thread? = null
 
     override val thread: Thread
@@ -55,6 +56,7 @@ internal actual object DefaultExecutor : EventLoopImplBase(), Runnable {
     private const val SHUTDOWN = 4
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var debugStatus: Int = FRESH
 
     private val isShutDown: Boolean get() = debugStatus == SHUTDOWN

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

@@ -29,6 +29,7 @@ internal object DebugProbesImpl {
     private val capturedCoroutines: Set<CoroutineOwner<*>> get() = capturedCoroutinesMap.keys
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var installations = 0
 
     /**

kotlinx-coroutines-core/jvm/src/internal/ResizableAtomicArray.kt

@@ -12,6 +12,7 @@ import java.util.concurrent.atomic.*
  */
 internal class ResizableAtomicArray<T>(initialLength: Int) {
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var array = AtomicReferenceArray<T>(initialLength)
 
     // for debug output

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

@@ -583,7 +583,8 @@ internal class CoroutineScheduler(
         }
 
         // guarded by scheduler lock, index in workers array, 0 when not in array (terminated)
-        @Volatile // volatile for push/pop operation into parkedWorkersStack
+        @Volatile
+        @OptIn(ExperimentalStdlibApi::class) // volatile for push/pop operation into parkedWorkersStack
         var indexInArray = 0
             set(index) {
                 name = "$schedulerName-worker-${if (index == 0) "TERMINATED" else index.toString()}"
@@ -634,6 +635,7 @@ internal class CoroutineScheduler(
          * This reference is set to [NOT_IN_STACK] when worker is physically not in stack.
          */
         @Volatile
+        @OptIn(ExperimentalStdlibApi::class)
         var nextParkedWorker: Any? = NOT_IN_STACK
 
         /*

kotlinx-coroutines-core/jvm/test/CancellableContinuationJvmTest.kt

@@ -63,9 +63,11 @@ class CancellableContinuationJvmTest : TestBase() {
 
     private class BlockingSource {
         @Volatile
+        @OptIn(ExperimentalStdlibApi::class)
         private var isCancelled = false
 
         @Volatile
+        @OptIn(ExperimentalStdlibApi::class)
         public var hasSubscriber = false
 
         public fun subscribe() {

kotlinx-coroutines-core/jvm/test/ConcurrentTestUtilities.kt

@@ -17,6 +17,7 @@ actual fun randomWait() {
 
 private object BlackHole {
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     var sink = 1
 }
 

kotlinx-coroutines-core/jvm/test/JobDisposeStressTest.kt

@@ -14,13 +14,17 @@ class JobDisposeStressTest: TestBase() {
     private val TEST_DURATION = 3 * stressTestMultiplier // seconds
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var done = false
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var job: TestJob? = null
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var handle: DisposableHandle? = null
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var exception: Throwable? = null
 
     private fun testThread(name: String, block: () -> Unit): Thread =
@@ -77,4 +81,4 @@ class JobDisposeStressTest: TestBase() {
 
     @Suppress("DEPRECATION_ERROR")
     private class TestJob : JobSupport(active = true)
-}
+}

kotlinx-coroutines-core/jvm/test/JobHandlersUpgradeStressTest.kt

@@ -24,9 +24,11 @@ class JobHandlersUpgradeStressTest : TestBase() {
     private val sink = atomic(0)
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var done = false
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var job: Job? = null
 
     class State {
@@ -94,4 +96,4 @@ class JobHandlersUpgradeStressTest : TestBase() {
         println("    Fired handler ${fired.value} times")
 
     }
-}
+}

kotlinx-coroutines-core/jvm/test/VirtualTimeSource.kt

@@ -27,9 +27,11 @@ internal inline fun withVirtualTimeSource(log: PrintStream? = null, block: () ->
 private const val NOT_PARKED = -1L
 
 private class ThreadStatus {
-    @Volatile @JvmField
+    @Volatile
+    @OptIn(ExperimentalStdlibApi::class) @JvmField
     var parkedTill = NOT_PARKED
-    @Volatile @JvmField
+    @Volatile
+    @OptIn(ExperimentalStdlibApi::class) @JvmField
     var permit = false
     var registered = 0
     override fun toString(): String = "parkedTill = ${TimeUnit.NANOSECONDS.toMillis(parkedTill)} ms, permit = $permit"
@@ -47,9 +49,11 @@ internal class VirtualTimeSource(
     private var checkpointNanos: Long = System.nanoTime()
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var isShutdown = false
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var time: Long = 0
 
     private var trackedTasks = 0

kotlinx-coroutines-core/jvm/test/channels/ChannelUndeliveredElementSelectOldStressTest.kt

@@ -40,6 +40,7 @@ class ChannelUndeliveredElementSelectOldStressTest(private val kind: TestChannel
     private val receiverDone = Channel<Boolean>(1)
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var lastReceived = -1L
 
     private var stoppedSender = 0L

kotlinx-coroutines-core/jvm/test/channels/ChannelUndeliveredElementStressTest.kt

@@ -40,6 +40,7 @@ class ChannelUndeliveredElementStressTest(private val kind: TestChannelKind) : T
     private val receiverDone = Channel<Boolean>(1)
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var lastReceived = -1L
 
     private var stoppedSender = 0L

kotlinx-coroutines-core/jvm/test/flow/CallbackFlowTest.kt

@@ -15,6 +15,7 @@ class CallbackFlowTest : TestBase() {
     private class CallbackApi(val block: (SendChannel<Int>) -> Unit) {
         var started = false
         @Volatile
+        @OptIn(ExperimentalStdlibApi::class)
         var stopped = false
         lateinit var thread: Thread
 

kotlinx-coroutines-core/jvm/test/guide/example-sync-02.kt

@@ -23,7 +23,8 @@ suspend fun massiveRun(action: suspend () -> Unit) {
     println("Completed ${n * k} actions in $time ms")    
 }
 
-@Volatile // in Kotlin `volatile` is an annotation 
+@OptIn(ExperimentalStdlibApi::class)
+@Volatile // in Kotlin `volatile` is an annotation
 var counter = 0
 
 fun main() = runBlocking {

kotlinx-coroutines-core/jvm/test/scheduling/WorkQueueStressTest.kt

@@ -22,6 +22,7 @@ class WorkQueueStressTest : TestBase() {
     private val producerQueue = WorkQueue()
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var producerFinished = false
 
     @Before

reactive/kotlinx-coroutines-reactive/src/Publish.kt

@@ -74,6 +74,7 @@ public class PublisherCoroutine<in T>(
     private val _nRequested = atomic(0L) // < 0 when closed (CLOSED or SIGNALLED)
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var cancelled = false // true after Subscription.cancel() is invoked
 
     override val isClosedForSend: Boolean get() = !isActive

reactive/kotlinx-coroutines-reactive/src/ReactiveFlow.kt

@@ -197,6 +197,7 @@ public class FlowSubscription<T>(
     private val requested = atomic(0L)
     private val producer = atomic<Continuation<Unit>?>(createInitialContinuation())
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var cancellationRequested = false
 
     // This code wraps startCoroutineCancellable into continuation

reactive/kotlinx-coroutines-reactor/src/Mono.kt

@@ -97,6 +97,7 @@ private class MonoCoroutine<in T>(
     private val sink: MonoSink<T>
 ) : AbstractCoroutine<T>(parentContext, false, true), Disposable {
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var disposed = false
 
     override fun onCompleted(value: T) {

ui/kotlinx-coroutines-android/src/AndroidExceptionPreHandler.kt

@@ -13,6 +13,7 @@ internal class AndroidExceptionPreHandler :
     AbstractCoroutineContextElement(CoroutineExceptionHandler), CoroutineExceptionHandler
 {
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var _preHandler: Any? = this // uninitialized marker
 
     // Reflectively lookup pre-handler.

ui/kotlinx-coroutines-android/src/HandlerDispatcher.kt

@@ -128,6 +128,7 @@ internal class HandlerContext private constructor(
     ) : this(handler, name, false)
 
     @Volatile
+    @OptIn(ExperimentalStdlibApi::class)
     private var _immediate: HandlerContext? = if (invokeImmediately) this else null
 
     override val immediate: HandlerContext = _immediate ?:
@@ -176,6 +177,7 @@ internal class HandlerContext private constructor(
     override fun hashCode(): Int = System.identityHashCode(handler)
 }
 
+@OptIn(ExperimentalStdlibApi::class)
 @Volatile
 private var choreographer: Choreographer? = null