Aké vlastnosti práce s dátovými tokmi poskytuje programovací jazyk Kotlin?

Kotlin ponúka vstavanú podporu pre korutiny pre asynchrónnej neblokujúcej práce, poskytujúc ľahšiu alternatívu k vlákna OS.

Vlastnosti práce s tokmi dát cez korutiny:

• Ľahkosť: Korutiny nie sú viazané na vlákna OS 1:1. Jedna korutina spotrebuje podstatne menej zdrojov.
• Štruktúrovaná konkurentnosť: Hierarchická štruktúra vytvárania korutín (rodič-dieťa) uľahčuje správu zrušení úloh a spracovanie chýb.
• Pozastavenie (Suspending Functions): Kľúčové slovo suspend umožňuje pozastaviť vykonávanie funkcie bez blokovania vlákna, a následne ho obnoviť.
• Kanály (Channels): Poskytujú spôsob bezpečnej komunikácie medzi korutinami prostredníctvom prenosu dát.

  // Príklad použitia Channel
  import kotlinx.coroutines.*
  import kotlinx.coroutines.channels.*
  
  fun main() = runBlocking {
      val channel = Channel<Int>()
      launch { // Posielajúca korutina
          for (x in 1..5) channel.send(x * x)
          channel.close() // Zatvorenie kanála po odoslaní
      }
      // Prijímajúca korutina
      for (y in channel) {
          println(y)
      }
      println("Hotovo!")
  }
  

• Flow (Toky dát): Predstavujú chladné asynchrónne toky dát, ktoré môžu emitovať viac hodnôt. Sú podobné RxJava Observable, ale s lepšou integráciou s korutinami.

  // Príklad použitia Flow
  import kotlinx.coroutines.*
  import kotlinx.coroutines.flow.*
  
  fun main() = runBlocking {
      flow { // Vytvorenie Flow
          for (i in 1..3) {
              delay(100) // Simulácia asynchrónnej práce
              emit(i) // Emitovanie hodnoty
          }
      }.collect { value -> // Zber hodnôt
          println(value)
      }
  }
  

• Dispečeri (Dispatchers): Určujú pooly vlákien, na ktorých budú vykonávané korutiny.
  • Dispatchers.Default: Pre ťažké výpočtové úlohy.
  • Dispatchers.IO: Pre operácie vstupno-výstupných operácií.
  • Dispatchers.Main: Pre aktualizáciu UI (dostupné na platformách s UI slučkou).
  • Dispatchers.Unconfined: Nie je obmedzené na konkrétne vlákno.
• Selektory (Select): Umožňujú čakať na dokončenie viacerých asynchrónnych operácií a vykonať akciu pri ich prvom dokončení.

Samozrejme, v Kotlin je možné pracovať aj s tradičnými Java vláknami (java.lang.Thread), ale korutiny sú preferovaným prístupom pre asynchrónnu a konkurentnú spracovanie dát vo väčšine prípadov.