Kādi mehānismi nodrošina kooperatīvo daudzuzdevumu izpildi korutīnās?

Korutīnās kooperatīvā daudzuzdevumu izpilde tiek realizēta ar šādiem mehānismiem:

• Suspension Points: Korutīna var tikt "apturēta" noteiktās vietās (suspension points), neblokējot pavedienu. Tas notiek, izsaucot suspend funkcijas. Apturēšanas laikā pavediens, kurā tika izpildīta korutīna, ir brīvs citiem uzdevumiem.

• Dispatchers: Korutīnas izmanto Dispatchers, lai noteiktu pavedienu baseinu, kurā tās tiks izpildītas. Korutīna var tikt apturēta vienā pavedienā un atsākt citā.

• Continuation: Katru reizi, kad korutīna tiek apturēta, tiek izveidots Continuation objekts, kas glabā korutīnas stāvokli šajā brīdī. Kad korutīna atsākas, tā izmanto šo objektu, lai atjaunotu savu stāvokli un turpinātu izpildi no vietas, kur tā tika apturēta.

• Cooperation: Izstrādātājs skaidri norāda apturēšanas punktus (suspend) kodā. Tas padara daudzuzdevumu izpildi "kooperatīvu" – korutīna brīvprātīgi nodod kontroli citai korutīnai vai uzdevumam noteiktās vietās, nevis tiek obligāti pārtraukta operētājsistēmas dēļ, kā tas ir preemptive daudzuzdevumu izpildē.

• Structured Concurrency: Korutīnas ir saistītas ar noteiktu redzamības jomu (CoroutineScope). Tas ļauj vienlaicīgi atcelt vairākas korutīnas un garantē, ka visas bērnu korutīnas tiks pabeigtas, kad tiks pabeigta vecāku joma.

// Piemērs suspend funkcijai, kas rada suspension point
suspend fun fetchDataFromNetwork(): String {
    // Tīkla pieprasījuma imitācija
    delay(1000) // Šī ir suspend funkcija - apturēšanas punkts
    return "Dati saņemti"
}

fun main() = runBlocking {
    // runBlocking izveido CoroutineScope un bloķē pašreizējo pavedienu līdz korutīnas pabeigšanai
    println("Sākums")

    launch {
        // Sākam korutīnu citā pavedienā (vai tajā pašā, atkarībā no dispatcher)
        val data = fetchDataFromNetwork() // Šeit korutīna var tikt apturēta
        println("Saņemts: $data")
    }

    println("Beigas (galvenais pavedienu nav bloķēts fetchDataFromNetwork)")
    // Galvenais pavedienu var veikt citas uzdevumus, kamēr fetchDataFromNetwork gaida
}