Kotlin, асинхрондук операциялар менен иштөө үчүн…

Котлин корутиндерди (coroutines) асинхрондук операцияларды жөнөкөйлөтүү үчүн сунуштайт жана жеңил агымдарды камсыздайт, алар негизги аткаруу агымын блоктебейт.

Негизги мүмкүнчүлүктөр:

Түзөөчү функциялар: suspend ачкыч сөзү менен белгиленген функциялар, алар токтоп жана улантылат. Алар аткаруу агымын блоктобойт.
```
suspend fun fetchData(): String {
    delay(1000) // Узун операцияны имитациялайбыз
    return "Маалымат алынды"
}
```
Корутин куруучулары: Корутиндарды ишке киргизүү үчүн колдонулган функциялар:
- launch: Жаңы корутинди ишке киргизет жана Job кайтарат (блоктогон эмес).
```
GlobalScope.launch {
    println("Корутин ишке кирди")
}
```
- async: Жаңы корутинди ишке киргизет жана Deferred<T> кайтарат (.await() чакырганда блоктогон).
```
val deferred = GlobalScope.async {
    fetchData()
}
// ...
val result = deferred.await() // Натыйжаны күтүп жатабыз
```
- runBlocking: Учурдагы агымды корутин аяктаганга чейин блоктоп турат (негизинен, блоктогон жана блоктогон эмес коддордун ортосунда көп колдонулат, мисалы, тесттерде).
```
runBlocking {
    val data = fetchData()
    println(data)
}
```
CoroutineContext: Корутиндин жүрүм-турумун аныктаган элементтердин жыйындысы, анын ичинде Dispatcher жана Job.
- Dispatcher: Корутин ишке ашырылып жаткан агымды же агымдар пулун аныктайт.
Dispatchers: Ичке объекттер, агымдарды башкаруу үчүн:
- Dispatchers.Default: Жалпы фонуулук агымдар пулу.
- Dispatchers.IO: Кирүү-чыгуу үчүн оптималдаштырылган (диск, тармак операциялары).
- Dispatchers.Main: негизги UI агымы (Android, JavaFX жана башка).
- Dispatchers.Unconfined: Корутинди учурдагы агымда баштайт, бирок токтогондон кийин каалаган агымда уланта алат.
```
GlobalScope.launch(Dispatchers.IO) {
    // Кирүү-чыгуу агымында ишке ашырылат
}
```
Структурланган конкуренция: Принцип, ага ылайык, корутиндердин ата-энеси (CoroutineScope) бар жана ата-энеси токтотулганда автоматтык түрдө токтотулат. Бул ресурстардын агып кетишин алдын алууга жана жашоо циклин башкарууну жеңилдетет.
```
// CoroutineScope автоматтык түрдө балдары корутиндерди башкарат
val scope = CoroutineScope(Dispatchers.Default)
val job = scope.launch {
    // ...
}
// Scope токтотулганда, бардык балдары корутиндер токтотулат
scope.cancel()
```
Каналдар: Корутиндер арасында маалыматтарды коопсуз өткөрүү үчүн каналдар. Алар:
- Unbuffered: Жөнөтүү гана кабыл алынгандан кийин болот.
- Buffered: Бир нече элементти жөнөтүүгө мүмкүндүк берет, блоктогонго чейин.
- Conflated: Жөнөтүлгөн акыркы элементти гана сактайт.
```
val channel = Channel<Int>()

scope.launch {
    for (x in 1..5) channel.send(x)
    channel.close()
}

scope.launch {
    for (y in channel) println(y)
}
```

Flow: Маалымат агымы, ал бир нече маанини асинхрондуу чыгара алат. RxJava Observable сыяктуу, бирок жеңилирээк жана корутиндер менен интеграцияланган.

fun simpleFlow(): Flow<Int> = flow {
    for (i in 1..3) {
        delay(100)
        emit(i) // Маалыматты чыгарыш
    }
}

runBlocking {
    simpleFlow().collect { value -> println(value) } // Маалыматты колдонуучу
}

Бул мүмкүнчүлүктөр асинхрондук кодду императивдүү стилиде жазууга мүмкүндүк берет, аны окуу жана тейлөө оңой болот, callback же Future колдонуу менен салыштырганда.

Kotlin, асинхрондук операциялар менен иштөө үчүн кандай мүмкүнчүлүктөрдү сунуштайт?