| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
| D | LockFreeTaskQueueTest.kt | 39 assertEquals(1, q.removeFirstOrNull()) in <lambda>()
42 assertEquals(2, q.removeFirstOrNull()) in <lambda>()
54 assertEquals(3, q.removeFirstOrNull()) in <lambda>()
57 assertEquals(4, q.removeFirstOrNull()) in <lambda>()
72 assertEquals(i, q.removeFirstOrNull()) in <lambda>()
|
| D | ThreadSafeHeapTest.kt | 40 assertEquals(n1, h.removeFirstOrNull()) in compareTo()
61 repeat(n) { assertEquals(Node(a[it]), h.removeFirstOrNull()) } in testRandomSort()
90 val headNode = h.removeFirstOrNull()!! // must not be null!!! in testRandomRemove()
|
| D | LockFreeLinkedListAddRemoveStressTest.kt | 31 val node = list.removeFirstOrNull() in testStressAddRemove()
|
| D | LockFreeLinkedListShortStressTest.kt | 68 val node = list.removeFirstOrNull() in <lambda>()
|
| D | LockFreeTaskQueueStressTest.kt | 66 val item = queue.removeFirstOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 358 ?: globalCpuQueue.removeFirstOrNull() in <lambda>()
359 ?: globalBlockingQueue.removeFirstOrNull() in <lambda>()
861 localQueue.poll() ?: globalBlockingQueue.removeFirstOrNull() in <lambda>()
863 globalBlockingQueue.removeFirstOrNull() in <lambda>()
886 globalCpuQueue.removeFirstOrNull()?.let { return it } in <lambda>()
887 return globalBlockingQueue.removeFirstOrNull() in <lambda>()
889 globalBlockingQueue.removeFirstOrNull()?.let { return it } in <lambda>()
890 return globalCpuQueue.removeFirstOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | LockFreeTaskQueueLCStressTest.kt | 30 fun removeFirstOrNull() = q.removeFirstOrNull() in close() method
|
| D | LockFreeListLCStressTest.kt | 34 val node = q.removeFirstOrNull() ?: return null in removeFirst()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | WorkQueueTest.kt | 85 var task: Task? = removeFirstOrNull() in drain()
89 task = removeFirstOrNull() in drain()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/internal/ |
| D | LinkedList.kt | 76 public fun removeFirstOrNull(): Node? { in removeFirstOrNull() method in kotlinx.coroutines.internal.LinkedListNode
112 override fun onComplete() { queue.removeFirstOrNull() } in onComplete()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/internal/ |
| D | LinkedList.kt | 76 public fun removeFirstOrNull(): Node? { in removeFirstOrNull() method in kotlinx.coroutines.internal.LinkedListNode
112 override fun onComplete() { queue.removeFirstOrNull() } in onComplete()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | LockFreeTaskQueue.kt | 57 fun removeFirstOrNull(): E? { in <lambda>() method
59 val result = cur.removeFirstOrNull() in <lambda>()
164 fun removeFirstOrNull(): Any? { in removeFirstOrNull() method
|
| D | ArrayQueue.kt | 21 public fun removeFirstOrNull(): T? { in removeFirstOrNull() method in kotlinx.coroutines.internal.ArrayQueue
|
| D | LockFreeLinkedList.common.kt | 38 public fun removeFirstOrNull(): LockFreeLinkedListNode? in addLast() method in kotlinx.coroutines.internal.LockFreeLinkedListNode
|
| D | ThreadSafeHeap.kt | 42 public fun removeFirstOrNull(): T? = synchronized(this) { in <lambda>() method in kotlinx.coroutines.internal.ThreadSafeHeap
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | EventLoop.common.kt | 68 val task = queue.removeFirstOrNull() ?: return false in <lambda>()
324 val result = (queue as Queue<Runnable>).removeFirstOrNull() in dequeue()
396 val delayedTask = _delayed.value?.removeFirstOrNull() ?: break in rescheduleAllDelayed()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Window.kt | 59 val element = current.removeFirstOrNull() ?: return in process()
|
| D | JSDispatcher.kt | 147 val element = removeFirstOrNull() ?: return@process in process()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/ |
| D | TestCoroutineDispatcher.kt | 170 pendingTasks += queue.removeFirstOrNull() ?: break in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Mutex.kt | 316 val waiter = state.removeFirstOrNull() in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | LockFreeLinkedList.kt | 280 public actual fun removeFirstOrNull(): Node? { in <lambda>() method in kotlinx.coroutines.internal.LockFreeLinkedListNode
|