Prin ce mecanisme se realizează multitaskingul cooperativ în corutine?

În corutine, multitasking-ul cooperativ se implementează prin următoarele mecanisme:

• Puncte de suspendare: Corutina poate fi "suspendată" în anumite puncte (puncte de suspendare), fără a bloca firul de execuție. Acest lucru se întâmplă la apelarea funcțiilor suspend. În timpul suspendării, firul în care se executa corutina este liber pentru alte sarcini.

• Dispatchers: Corutinele folosesc Dispatchers pentru a determina pool-ul de fire pe care se vor executa. O corutină poate fi suspendată pe un fir și reluată pe altul.

• Continuare: De fiecare dată când o corutină este suspendată, se creează un obiect Continuation care stochează starea corutinei în acel moment. Când corutina este reluată, folosește acest obiect pentru a-și restabili starea și a continua de unde a fost suspendată.

• Cooperare: Dezvoltatorul indică explicit punctele de suspendare (suspend) în cod. Acest lucru face ca multitasking-ul să fie "cooperativ" – corutina cedează voluntar controlul către o altă corutină sau sarcină în anumite puncte, în loc să fie întreruptă forțat de sistemul de operare, ca în cazul multitasking-ului preemptiv.

• Concurență structurată: Corutinele sunt legate de o anumită arie de vizibilitate (CoroutineScope). Acest lucru permite anularea unui grup de corutine simultan și garantează că toate corutinele copil vor fi finalizate la încheierea ariei părinte.

// Exemplu de funcție suspend care creează un punct de suspendare
suspend fun fetchDataFromNetwork(): String {
    // Simulare de solicitare de rețea
    delay(1000) // Este o funcție suspend - punct de suspendare
    return "Date primite"
}

fun main() = runBlocking {
    // runBlocking creează un CoroutineScope și blochează firul curent până când corutina se finalizează
    println("Început")

    launch {
        // Pornește o corutină pe un alt fir (sau același, în funcție de dispatcher)
        val data = fetchDataFromNetwork() // Aici, corutina poate fi suspendată
        println("Primite: $data")
    }

    println("Sfârșit (firul principal nu este blocat de fetchDataFromNetwork)")
    // Firul principal poate executa alte sarcini în timp ce fetchDataFromNetwork așteaptă
}