Кадом механизмҳо дар корутинҳо мултизадаҳии ҳамкориро амалӣ мекунанд?

Корутинах кооперативна многозадачність реалізується за допомогою таких механізмів:

• Suspension Points: Корутина може бути "припинена" у визначених точках (suspension points), не блокуючи потік. Це відбувається при виклику функцій suspend. Під час припинення потік, на якому виконувалася корутина, вільний для виконання інших задач.

• Dispatchers: Корутини використовують диспетчери (Dispatchers) для визначення пулу потоків, на яких вони будуть виконуватися. Корутина може бути припинена на одному потоці і відновлена на іншому.

• Continuation: Щоразу, коли корутина припиняється, створюється об'єкт Continuation, який зберігає стан корутини в цей момент. Коли корутина відновлюється, вона використовує цей об'єкт для відновлення свого стану і продовження виконання з того місця, де вона була припинена.

• Cooperation: Розробник явно вказує точки припинення (suspend) у коді. Це робить багатозадачність "кооперативною" – корутина добровільно передає контроль іншій корутині або задачі в певних місцях, замість того, щоб бути примусово перерваною операційною системою, як у випадку preemptive багатозадачності потоків.

• Structured Concurrency: Корутини прив'язані до певної області видимості (CoroutineScope). Це дозволяє скасовувати групу корутин одночасно і гарантує, що всі дочірні корутини будуть завершені при завершенні батьківської області.

// Приклад suspend функції, яка створює suspension point
suspend fun fetchDataFromNetwork(): String {
    // Імітація мережевого запиту
    delay(1000) // Це suspend функція - точка припинення
    return "Дані отримано"
}

fun main() = runBlocking {
    // runBlocking створює CoroutineScope і блокує поточний потік до завершення корутини
    println("Початок")

    launch {
        // Запускаємо корутину на іншому потоці (або тому ж, залежно від диспетчера)
        val data = fetchDataFromNetwork() // Тут корутина може бути припинена
        println("Отримано: $data")
    }

    println("Кінець (основний потік не заблокований fetchDataFromNetwork)")
    // Основний потік може виконувати інші задачі, поки fetchDataFromNetwork чекає
}