Класс ExecutorCoroutineDispatcher Правильная реализация

    class dispatch : ExecutorCoroutineDispatcher() {
        private val services = Executors.newCachedThreadPool()
    
        override val executor: Executor
            get() = services
    
        override fun dispatch(context: CoroutineContext, block: Runnable) {
            println("dispatch ")
            if (this.isDispatchNeeded(context)){
                executor.execute(block)
            }else{
                Dispatchers.Unconfined.dispatch(context , block) 
            }
        }
    
        override fun isDispatchNeeded(context: CoroutineContext): Boolean {
            println("isDispatchedNeeded ")
 // Implement your custom logic here to determine if dispatch is needed
            return false // assuming yield() call in loop so return false 
        }
    
        override fun close() {
            services.shutdown()
        }
    }
        fun main() {
            runBlocking {
                launch(dispatch()) {
                    for (i in 1..3) {
                        println("start")
                        yield()// dispatch() call in loop may cause stackOverFlowError
                        println("end")
                    }
                }
        
                launch(dispatch()) {
                    println("some suspend function")
                    work() // some suspend work 
                }
            }
        }
suspend fun work() {
    delay(1000) // Simulating some suspend work
}

Я прочитал это диспетчер(). я не мог понять, как лучше реализовать эту функцию в соответствии с документацией по диспетчеризации (). как они говорят о

Этот метод должен гарантировать, что данный блок в конечном итоге будет вызван, иначе система может зайти в состояние тупика и никогда из него не выйти.

Этот метод не должен сразу вызывать блок . Это может привести к возникновению StackOverflowError при многократном вызове диспетчеризации, например, когда выход вызывается в цикле. Чтобы выполнить блок на месте, необходимо вернуть false из isDispatchNeeded и в таких случаях делегировать реализацию диспетчеризации Dispatchers.Unconfined.dispatch. Для этого механизм сопрограмм обеспечивает выполнение на месте и формирует цикл событий, чтобы избежать несвязанной рекурсии.

---> в моем коде, когда в цикле есть метод yield(), то isDispatchNeeded возвращает false, а при отправке используйте Unconfined Dispatcher, как указано выше в документации, чтобы избежать ошибки stackoverflow, но в документации, как я могу справиться, когда нам нужно немедленно вызвать блок [runnable] чтобы избежать тупика.

пожалуйста, кто-нибудь Исправьте мой код, который правильно обрабатывает отправку сопрограмм, учитывая, вызывается ли диспетчер() в цикле или нет, и должен ли он обеспечить правильную обработку ошибок и управление исключениями в диспетчеризации(), isDispatchedNeeded(), которые обрабатывают такие проблемы, как взаимоблокировка или StackOverflowError и т. д.?