Jaké vlastnosti práce s datovými proudy nabízí programovací jazyk Kotlin?

Kotlin nabízí vestavěnou podporu pro korutiny (coroutines) pro asynchronní, neblokující práci, čímž poskytuje lehčí alternativu k vláknům operačního systému.

Vlastnosti práce s datovými proudy přes korutiny:

• Lehkost: Korutiny nejsou vázány na vlákna OS 1:1. Jedna korutina spotřebuje výrazně méně zdrojů.
• Strukturovaná konkurence: Hierarchická struktura tvorby korutin (rodič- potomek) zjednodušuje správu zrušení úkolů a zpracování chyb.
• Pozastavení (Funkce pozastavení): Klíčové slovo suspend umožňuje pozastavit provádění funkce bez blokování vlákna a poté ji obnovit.
• Kanály (Channels): Nabízejí bezpečný způsob komunikace mezi korutinami prostřednictvím přenosu dat.

  // Příklad použití kanálu
  import kotlinx.coroutines.*
  import kotlinx.coroutines.channels.*
  
  fun main() = runBlocking {
      val channel = Channel<Int>()
      launch { // Vysílač korutina
          for (x in 1..5) channel.send(x * x)
          channel.close() // Uzavření kanálu po odeslání
      }
      // Příjemce korutina
      for (y in channel) {
          println(y)
      }
      println("Hotovo!")
  }
  

• Flow (Datové proudy): Představují studené, asynchronní datové proudy, které mohou emitovat více hodnot. Jsou podobné RxJava Observable, ale s lepší integrací s korutinami.

  // Příklad použití Flow
  import kotlinx.coroutines.*
  import kotlinx.coroutines.flow.*
  
  fun main() = runBlocking {
      flow { // Vytvoření Flow
          for (i in 1..3) {
              delay(100) // Simulace asynchronní práce
              emit(i) // Emitování hodnoty
          }
      }.collect { value -> // Sbírání hodnot
          println(value)
      }
  }
  

• Dispečeři (Dispatchers): Určují pooly vláken, na kterých budou korutiny prováděny.
  • Dispatchers.Default: Pro náročné výpočetní úkoly.
  • Dispatchers.IO: Pro operace vstup/výstup.
  • Dispatchers.Main: Pro aktualizaci UI (dostupné na platformách s UI event loopem).
  • Dispatchers.Unconfined: Není omezeno na konkrétní vlákno.
• Selektory (Select): Umožňují čekat na dokončení několika asynchronních operací a provést akci při dokončení první z nich.

Samozřejmě, v Kotlinu je možné pracovat i s tradičními vlákny Java (java.lang.Thread), ale korutiny jsou preferovaným přístupem k asynchronnímu a konkurenčnímu zpracování dat ve většině případů.