Quali meccanismi consentono la multitasking cooperativa nelle coroutine?

Nelle coroutine, il multitasking cooperativo viene implementato attraverso i seguenti meccanismi:

• Punti di sospensione: La coroutine può essere "sospesa" in punti specifici (punti di sospensione), senza bloccare il thread. Questo avviene chiamando funzioni suspend. Durante la sospensione, il thread in cui la coroutine era in esecuzione è libero di eseguire altri compiti.

• Dispatchers: Le coroutine usano Dispatchers per determinare il pool di thread su cui verranno eseguite. Una coroutine può essere sospesa su un thread e ripresa su un altro.

• Continuazione: Ogni volta che una coroutine viene sospesa, viene creato un oggetto Continuation che memorizza lo stato della coroutine in quel momento. Quando la coroutine viene ripresa, utilizza questo oggetto per ripristinare il suo stato e continuare dall'endroit in cui era stata sospesa.

• Cooperazione: Lo sviluppatore indica esplicitamente i punti di sospensione (suspend) nel codice. Questo rende il multitasking "cooperativo" – la coroutine cede volontariamente il controllo a un'altra coroutine o task in determinati punti, invece di essere forzatamente interrotta dal sistema operativo, come nel multitasking preemptive.

• Concorrenza strutturata: Le coroutine sono legate a un ambito (CoroutineScope). Questo permette di cancellare un gruppo di coroutine contemporaneamente e garantisce che tutte le coroutine figlie siano completate al termine dell'ambito genitore.

// Esempio di funzione suspend che crea un punto di sospensione
suspend fun fetchDataFromNetwork(): String {
    // Simulazione di una richiesta di rete
    delay(1000) // È una funzione suspend - punto di sospensione
    return "Dati ricevuti"
}

fun main() = runBlocking {
    // runBlocking crea un CoroutineScope e blocca il thread corrente fino al completamento della coroutine
    println("Inizio")

    launch {
        // Avvia una coroutine su un altro thread (o sullo stesso, a seconda del dispatcher)
        val data = fetchDataFromNetwork() // Qui la coroutine può essere sospesa
        println("Ricevuto: $data")
    }

    println("Fine (il thread principale non è bloccato da fetchDataFromNetwork)")
    // Il thread principale può eseguire altre attività mentre fetchDataFromNetwork aspetta
}