Kaip užtikrinama galimybė sustabdyti funkcijos vykdymą su suspend modifikatoriumi?

Funkcijos sustabdymas užtikrinamas dėka kurotinų ir tęsinio (continuations) mechanizmo:

1. suspend modifikatorius: Nurodo kompiliatoriui, kad funkcija gali būti sustabdyta ir atnaujinta vėliau be srauto blokavimo. Tai nereiškia, kad ji būtinai sustos:

2. Kompiliatoriaus transformacija: Kompiliatorius paverčia suspend funkciją į valdymo mašiną. Ši mašina stebi funkcijos vykdymo tašką ir jos vietinius kintamuosius:

3. Tęsinys (Continuation): Kai kviečiama suspend funkcija, jai perduodamas paslėptas Continuation parametras. Šis Continuation objektas turi callback, kuris bus iškviestas po asinchroninės operacijos pabaigos ir atnaujins funkciją nuo sustojimo taško. Jis taip pat saugo kontekstą (dispetcherį, užduoties kontekstą ir kt.):

4. Sustabdymas: Kai suspend funkcija pasiekia tašką, kuriame reikia atlikti asinchroninę operaciją (pvz., tinklo užklausą, duomenų bazės skaitymą), ji vietoj bloko paima esamą būseną (vietinius kintamuosius, vykdymo tašką), išsaugo ją Continuation objekte ir grąžina valdymą kviečiančiai kode. Srautas atlaisvinamas kitoms užduotims vykdyti:

5. Atnaujinimas: Kai asinchroninė operacija baigiasi, jos susijęs callback (saugomas Continuation) yra iškviečiamas. Šis callback praneša korutinui, kad jis gali būti atnaujintas. Korutina naudoja išsaugotą būseną iš Continuation, kad atstatytų vykdymo kontekstą ir tęsia vykdymą nuo sustojimo taško.

// Pavyzdys: suspend funkcija, imituojanti delsimo laiką
suspend fun fetchData(): String {
    // Čia vyksta sustabdymas.
    // Korutina išsaugo būseną ir atlaisvina srautą.
    delay(1000) // kotlinx.coroutines suspend funkcija
    // Po 1000 ms callback `Continuation` yra iškviečiamas,
    // ir korutina tęsia vykdymą nuo šios vietos.
    return "Duomenys įkelti"
}