override fun run()

in kotlinx-coroutines-core/common/src/internal/LimitedDispatcher.kt [119:144]

• 22 lines of code
• 6 McCabe index (conditional complexity)

        override fun run() {
            try {
                var fairnessCounter = 0
                while (true) {
                    try {
                        currentTask.run()
                    } catch (e: Throwable) {
                        handleCoroutineException(EmptyCoroutineContext, e)
                    }
                    currentTask = obtainTaskOrDeallocateWorker() ?: return
                    // 16 is our out-of-thin-air constant to emulate fairness. Used in JS dispatchers as well
                    if (++fairnessCounter >= 16 && dispatcher.safeIsDispatchNeeded(this@LimitedDispatcher)) {
                        // Do "yield" to let other views execute their runnable as well
                        // Note that we do not decrement 'runningWorkers' as we are still committed to our part of work
                        dispatcher.safeDispatch(this@LimitedDispatcher, this)
                        return
                    }
                }
            } catch (e: Throwable) {
                // If the worker failed, we should deallocate its slot
                synchronized(workerAllocationLock) {
                    runningWorkers.decrementAndGet()
                }
                throw e
            }
        }