Kokias duomenų srautų valdymo savybes siūlo Kotlin programavimo kalba?

Kotlin siūlo integruotą korutinų (coroutines) palaikymą asinchroniniam, neblokuojančiam darbui, suteikdamas lengvesnę alternatyvą OS srautams.

Duomenų srautų valdymas per korutinas:

• Lengvumas: Korutinos nėra susietos su OS srautais 1:1. Viena korutina sunaudoja žymiai mažiau išteklių.
• Struktūruota konkurencija: Hierarchinė korutinų kūrimo struktūra (tėvas-vaikas) palengvina užduočių atšaukimą ir klaidų apdorojimą.
• Sustabdymas (Suspending Functions): suspend žodis leidžia laikinai sustabdyti funkcijos vykdymą be srauto blokavimo, ir vėl jį atnaujinti.
• ** Kanalai (Channels):** užtikrina saugų komunikacijos būdą tarp korutinų per duomenų perdavimą.

  // Kanalų naudojimo pavyzdys
  import kotlinx.coroutines.*
  import kotlinx.coroutines.channels.*
  
  fun main() = runBlocking {
      val channel = Channel<Int>()
      launch { // Siuntėjas
          for (x in 1..5) channel.send(x * x)
          channel.close() // Kanalų uždarymas
      }
      // Gavimo korutina
      for (y in channel) {
          println(y)
      }
      println("Baigta!")
  }
  

• Flow (Duomenų srautai): Šaltas asinchroninis duomenų srautas, kuris gali skleisti daug reikšmių. Panašus į RxJava Observable, bet geresnė integracija su korutinomis.

  // Flow naudojimo pavyzdys
  import kotlinx.coroutines.*
  import kotlinx.coroutines.flow.*
  
  fun main() = runBlocking {
      flow { // Flow kūrimas
          for (i in 1..3) {
              delay(100) // Asinchroninio darbo imitacija
              emit(i) // Reikšmės išsiuntimas
          }
      }.collect { value -> // Reikšmių rinkimas
          println(value)
      }
  }
  

• Dispečeriai (Dispatchers): Nustato srautų siuntimo grupes, kuriose bus vykdomi korutinai.
  • Dispatchers.Default: Sudėtingiems skaičiavimams.
  • Dispatchers.IO: I/O operacijoms.
  • Dispatchers.Main: UI atnaujinimui (pasiekiama platformose su UI ciklu).
  • Dispatchers.Unconfined: Neribojama konkrečiu srautu.
• Pasirinkėjai (Select): leidžia laukti kelių asinchroninių operacijų ir vykdyti veiksmą, kai viena iš jų baigiasi pirmoji.

Žinoma, Kotlin taip pat galima dirbti su tradiciniais Java srautais (java.lang.Thread), tačiau korutinai yra pageidaujamas požiūris į asinchroninį ir konkurencingą duomenų apdorojimą daugeliu atvejų.