Чрез кои механизми в корутините се реализира кооперативната многозадачност?

В корутините кооперативната многозадачност се реализира чрез следните механизми:

• Точки на спиране: Корутината може да бъде "спряна" на определени точки (точки на спиране), без да блокира нишката. Това се случва при извикване на функции suspend. По време на спирането, нишката, в която е изпълнявана корутината, е свободна за други задачи.

• Dispatchers: Корутините използват Dispatchers, за да определят пул от нишки, на които ще се изпълняват. Корутината може да бъде спряна на един нишка и възобновена на друга.

• Продължение: Всеки път, когато корутината е спряна, се създава обект Continuation, който запазва състоянието на корутината в този момент. Когато корутината се възобнови, тя използва този обект, за да възстанови състоянието си и да продължи от мястото, където е била спряна.

• Сътрудничество: Разработчикът явно указва точките на спиране (suspend) в кода. Това прави многозадачността "сътрудническа" – корутината доброволно предава контрола на друга корутина или задача на определени места, вместо да бъде принудително прекъсната от операционната система, както при предимптивната многозадачност.

• Структурирана конкуренция: Корутините са свързани с определена област (CoroutineScope). Това позволява да се отменя група корутин едновременно и гарантира, че всички дъщерни корутини ще бъдат завършени при приключване на родителската област.

// Пример за suspend функция, създаваща точка на спиране
suspend fun fetchDataFromNetwork(): String {
    // Имитация на мрежов заявка
    delay(1000) // Това е suspend функция - точка на спиране
    return "Данни получени"
}

fun main() = runBlocking {
    // runBlocking създава CoroutineScope и блокира текущия поток до завършване на корутината
    println("Начало")

    launch {
        // Стартиране на корутина на друг поток (или същия, в зависимост от диспетчера)
        val data = fetchDataFromNetwork() // Тук корутината може да бъде спряна
        println("Получено: $data")
    }

    println("Край (основният поток не е блокиран от fetchDataFromNetwork)")
    // Основният поток може да изпълнява други задачи, докато fetchDataFromNetwork чака
}