Kotlinде көп иштөөчүнү кантип ишке ашыруу керек…

Котлинде көп агымдуу иштетүү бир нече жол менен ишке ашырылышы мүмкүн:

Стандарттык Java агымдары (Threads):

// Runnable интерфейсин ишке ашыруу
class MyRunnable : Runnable {
    override fun run() {
        // Өзүнчө агымда ишке ашырылчу код
        println("Салам агымдан: ${Thread.currentThread().name}")
    }
}

fun main() {
    // Runnableдин экземплярин түзүү
    val runnable = MyRunnable()
    // Runnable менен Thread объектисин түзүү
    val thread = Thread(runnable)
    // Агымды ишке киргизүү
    thread.start()
}

же lambda билдирүүсү менен:

fun main() {
    val thread = Thread {
        // Өзүнчө агымда ишке ашырылчу код
        println("Салам агымдан: ${Thread.currentThread().name}")
    }
    thread.start()
}

Kotlin Coroutines (Корутины): Бул сунушталган жана заманбап ыкма, ал жеңил салмактуу көп агымдуу иштетүүнү камсыз кылат.

import kotlinx.coroutines.*

fun main() = runBlocking {
    // Глобалдык scope ичинде жаңы корутин түзүү
    launch {
        delay(1000L) // Блоктогон эмес 1 секунддук кечиктирүү
        println("Корутинадан салам")
    }
    // Негизги агым ишин улантат
    println("Негизги агымдан салам")
    // runBlocking бардык ички корутиндердин аяктоосун күтөт
}

Корутиндердин ар кандай куруучуларынын мисалдары:

launch: Жаңы корутин түзөт, кайтарымсыз.

import kotlinx.coroutines.*

fun main() = runBlocking {
    launch {
        println("Бул корутина жөн гана ишти аткарат")
    }
}

async: Жаңы корутин түзөт, натыйжаны Deferred аркылуу кайтарат.

import kotlinx.coroutines.*

fun main() = runBlocking {
    val deferredResult = async {
        delay(1000L)
        "Корутинадан натыйжа"
    }
    val result = deferredResult.await() // Натыйжаны күтүү
    println(result)
}

RxKotlin/RxJava: Реактивдүү программалоо ошондой эле асинхрондук операциялар жана көп агым менен иштөө үчүн планировщиктерди (Schedulers) колдонууга мүмкүндүк берет.

import io.reactivex.rxjava3.core.Observable
import io.reactivex.rxjava3.schedulers.Schedulers

fun main() {
    Observable.just("Асинхрондук элемент")
        .subscribeOn(Schedulers.io()) // Ишке кирүү I/O агымында
        .observeOn(Schedulers.computation()) // Натыйжаларды эсептөө агымында байкоо
        .subscribe { item ->
            println("Алынып жатат: $item агымда ${Thread.currentThread().name}")
        }

    Thread.sleep(2000) // Асинхрондук операциялардын аяктоосун күтүү
}

Методду тандоо конкреттүү тапшырга көз каранды. Көпчүлүк заманбап Kotlin колдонмолорунда корутиндер артыкчылыкка ээ, анткени алар жеңил, колдонуу оңой жана тилге бекитилген. Java агымдары төмөнкү деңгээлдеги көзөмөл үчүн ылайыктуу, ал эми реактивдүү китепканалар — маалымат агымдары менен иштөө үчүн.

Kotlinде көп иштөөчүнү кантип ишке ашыруу керек?