Akými mechanizmami sa v korutinách realizuje kooperatívna multitasking?

V korutínach sa kooperatívna multitasking realizuje pomocou týchto mechanizmov:

• Suspension Points: Korutína môže byť "pozastavená" na určitých bodoch (suspension points), bez blokovania vlákna. To sa deje pri volaní funkcií suspend. Počas pozastavenia je vlákno, na ktorom sa korutína vykonávala, voľné na vykonávanie iných úloh.

• Dispatchers: Korutíny používajú dispatcher (Dispatchers) na určenie vlákna alebo vlákien, na ktorých budú vykonávané. Korutína môže byť pozastavená na jednom vlákne a obnovená na inom.

• Continuation: Každýkrát, keď sa korutína pozastaví, vytvorí sa objekt Continuation, ktorý uchováva stav korutiny v danom momente. Keď sa korutína obnoví, používa tento objekt na obnovenie svojho stavu a pokračovanie v vykonávaní od miesta, kde bola pozastavená.

• Cooperation: Vývojár výslovne určuje body pozastavenia (suspend) v kóde. To robí multitasking "kooperatívnym" – korutína dobrovoľne odovzdáva kontrolu inej korutíne alebo úlohe na určitých miestach, namiesto toho, aby bola nútene prerušovaná operačným systémom, ako je to v prípade preemptive multitaskingu vlákien.

• Structured Concurrency: Korutíny sú viazané na určitú oblasť viditeľnosti (CoroutineScope). To umožňuje zrušiť skupinu korutín naraz a zaručuje, že všetky dcérske korutiny budú ukončené pri ukončení rodičovskej oblasti.

// Príklad suspend funkcie, ktorá vytvára suspension point
suspend fun fetchDataFromNetwork(): String {
    // Napodobnenie sieťovej požiadavky
    delay(1000) // Ide o suspend funkciu - bod pozastavenia
    return "Dáta získané"
}

fun main() = runBlocking {
    // runBlocking vytvára CoroutineScope a blokuje aktuálne vlákno do ukončenia korutiny
    println("Začiatok")

    launch {
        // Spúšťame korutínu na inom vlákne (alebo tom istom, v závislosti od dispatcher)
        val data = fetchDataFromNetwork() // Tu môže byť korutína pozastavená
        println("Získané: $data")
    }

    println("Koniec (hlavné vlákno nie je zablokované fetchDataFromNetwork)")
    // Hlavné vlákno môže vykonávať iné úlohy, zatiaľ čo fetchDataFromNetwork čaká
}