Add more @InternalCoroutinesApi to internal package

Author: qwwdfsad

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

@@ -5,6 +5,7 @@
 package kotlinx.coroutines.experimental.internal
 
 import kotlinx.atomicfu.*
+import kotlinx.coroutines.experimental.*
 
 private typealias Node = LockFreeLinkedListNode
 
@@ -53,6 +54,7 @@ public actual typealias AbstractAtomicDesc = LockFreeLinkedListNode.AbstractAtom
  * @suppress **This is unstable API and it is subject to change.**
  */
 @Suppress("LeakingThis")
+@InternalCoroutinesApi
 public actual open class LockFreeLinkedListNode {
     private val _next = atomic<Any>(this) // Node | Removed | OpDescriptor
     private val _prev = atomic<Any>(this) // Node | Removed

core/kotlinx-coroutines-core/src/internal/LockFreeMPSCQueue.kt

@@ -5,6 +5,7 @@
 package kotlinx.coroutines.experimental.internal
 
 import kotlinx.atomicfu.*
+import kotlinx.coroutines.experimental.*
 import java.util.concurrent.atomic.*
 
 private typealias Core<E> = LockFreeMPSCQueueCore<E>
@@ -22,7 +23,8 @@ private typealias Core<E> = LockFreeMPSCQueueCore<E>
  *
  * @suppress **This is unstable API and it is subject to change.**
  */
-class LockFreeMPSCQueue<E : Any> {
+@InternalCoroutinesApi
+internal class LockFreeMPSCQueue<E : Any> {
     private val _cur = atomic(Core<E>(Core.INITIAL_CAPACITY))
 
     // Note: it is not atomic w.r.t. remove operation (remove can transiently fail when isEmpty is false)

core/kotlinx-coroutines-core/src/internal/ThreadSafeHeap.kt

@@ -10,6 +10,7 @@ import java.util.*
 /**
  * @suppress **This is unstable API and it is subject to change.**
  */
+@InternalCoroutinesApi
 public interface ThreadSafeHeapNode {
     public var heap: ThreadSafeHeap<*>?
     public var index: Int
@@ -20,6 +21,7 @@ public interface ThreadSafeHeapNode {
  *
  * @suppress **This is unstable API and it is subject to change.**
  */
+@InternalCoroutinesApi
 public class ThreadSafeHeap<T> : SynchronizedObject() where T: ThreadSafeHeapNode, T: Comparable<T> {
     private var a: Array<T?>? = null
 

core/kotlinx-coroutines-core/src/scheduling/Dispatcher.kt

@@ -26,6 +26,7 @@ internal object DefaultScheduler : ExperimentalCoroutineDispatcher() {
  * @suppress **This is unstable API and it is subject to change.**
  */
 // TODO make internal (and rename) after complete integration
+@InternalCoroutinesApi
 open class ExperimentalCoroutineDispatcher(
     private val corePoolSize: Int,
     private val maxPoolSize: Int,