runBlocking — bu nədir, bloklayan körpü və necə işləyir

runBlocking nədir?

runBlocking — Kotlin dilində yeni CoroutineScope yaradan və verilən korutinanı işə salan, onun tamamlanmasına qədər cari thread-i bloklayan funksiyadır. Bütün digər Coroutine Builder-lərdən fərqli olaraq, runBlocking suspend-funksiya deyil və adi sinxron koddan çağırıla bilər. runBlocking-in imzası CoroutineContext və suspend-blok qəbul edir, T tipli nəticə qaytarır.

public fun <T> runBlocking(
    context: CoroutineContext = EmptyCoroutineContext,
    block: suspend CoroutineScope.() -> T
): T

runBlocking cari thread-də yeni event-loop işə salır. Korutina suspend-funksiya çağırdıqda (məsələn, delay() və ya await()), runBlocking thread-i bloklayır və dayandırılmış korutina bərpa olunana qədər eyni thread-də digər planlaşdırılmış korutinaları icra edir. Bu kooperativ bloklamadır — thread boş dayanmır, digər korutinaları emal edir.

runBlocking necə işləyir

runBlocking-in daxili mexanizmi event-loop-a əsaslanır: suspend-funksiya çağırıldıqda, runBlocking cari blokun icrasını dayandırır və növbədən digər korutinaları işə salır. Suspend-funksiya tamamlandıqda icra bərpa olunur. Bu dövr bütün korutinalar tamamlanana qədər davam edir.

Event-loop-un daxili quruluşu

runBlocking korutinaları icra etmək üçün öz təkthreadli hovuzundan istifadə edir. Dispatchers.IO və ya Default-dan fərqli olaraq, runBlocking thread-ləri dəyişmir — bütün korutinaları cari thread-də emal edir, onların icrasını növbələşdirir. Bu, eyni thread-də icraya zəmanət verən yeganə bilderdir.

fun main() {
    val threadName = Thread.currentThread().getName()
    println("runBlocking-dən əvvəl $threadName")

    val result = runBlocking {
        println("runBlocking daxilində ${Thread.currentThread().getName()}")
        delay(500L)
        "Done"
    }

    println("runBlocking-dən sonra: $result")
}

Nəticə göstərəcək ki, hər üç println eyni thread-də icra olunur. runBlocking thread-i dəyişmir, əksinə event-loop vasitəsilə bir thread daxilində kooperativ çoxtapşırıqlılıq təşkil edir.

runBlocking nə vaxt istifadə edilməlidir

runBlocking üç ssenaridə əsaslandırılmışdır: konsol tətbiqlərində main() giriş nöqtəsi, suspend-funksiyaların vahid testləri və körpü — callback əsaslı və ya bloklayan kitabxanalardan suspend-kodun çağırılması. Android-in production-kodunda əsas thread-də istifadə qəti qadağandır.

Android testləri üçün runBlocking əvəzinə kotlinx-coroutines-test kitabxanasından TestDispatcher istifadə edin. Bu, vaxta nəzarət, avtomatik sıfırlama və test izolyasiyası təmin edir.

runBlocking alternativləri

Əksər ssenarilərdə runBlocking asinxron alternativlərlə əvəz edilə bilər və edilməlidir. Android üçün bunlar viewModelScope, lifecycleScope və ya düzgün dispetçerli CoroutineScope-dur. Testlər üçün — TestCoroutineDispatcher və runTest.

    // Pis: Android əsas thread-də runBlocking
runBlocking(Dispatchers.Main) {
    val result = networkApi.fetchData()
    textView.setText(result)
}

// Yaxşı: lifecycleScope
lifecycleScope.launch {
    val result = withContext(Dispatchers.IO) { networkApi.fetchData() }
    textView.setText(result)
}

Testlər üçün əvəz runTest-dir kotlinx-coroutines-test kitabxanasından. O, virtual vaxt ilə TestCoroutineScope yaradır, gecikmələri real gözləmə olmadan test etməyə imkan verir. Bu testləri sürətləndirir və determinist edir.

runBlocking istifadə nümunələri

Ən çox yayılmış ssenari — suspend-funksiyaların test edilməsidir. Testlərdə runBlocking korutinanın nəticəsini sinxron gözləməyə imkan verir, arxitekturanı dəyişmədən. İkinci ssenari — callback API-si olan kitabxanalardır, burada suspend-funksiyalar runBlocking vasitəsilə bloklayan kontekstdən çağırılır.

// Suspend funksiyasını runBlocking ilə test et
class RepositoryTest {
    @Test
    fun `fetchUser returns correct data`() {
        val repository = UserRepository(FakeApi())

        val result = runBlocking {
            repository.fetchUser("123")
        }

        assertEquals("John", result.name)
        assertEquals("john@test.com", result.email)
    }
}

Callback və suspend dünyası arasında körpü üçün callback-lər əvəzinə CompletableDeferred-i runBlocking ilə kombinasiyada istifadə edin — bu, asinxron əməliyyat zəncirlərini sadələşdirir və kodun oxunaqlılığını artırır.

Yanlış istifadənin təhlükələri

runBlocking-in yanlış istifadəsi bloklayan yanaşmadan korutinalara keçid zamanı ən çox rast gəlinən səhvlərdən biridir. Əsas problemlər: Android Main-Thread-də çağırış, runBlocking-in iç-içə yerləşdirilməsi, asinxron funksiyalar daxilində istifadə və runBlocking vasitəsilə uzun müddətli əməliyyatların işə salınması.

• ANR — Android Main-Thread-də runBlocking UI renderini 5 saniyədən çox bloklayır
• Deadlock — eyni thread-də korutina daxilində iç-içə runBlocking qarşılıqlı blokadaya səbəb olur
• Dispetçerlərlə qarışıqlıq — fon thread-də runBlocking daxilində Dispatchers.Main Looper-ə malik deyil və xəta ilə nəticələnir
• Yaddaş sızmaları — Activity/Fragment məhv olduqda runBlocking avtomatik ləğv edilmir

Qızıl qayda: runBlocking körpüdür, əvəz deyil. Yalnız bloklayan və bloklamayan dünyanı birləşdirmək üçün istifadə edin. Bütün digər tapşırıqlar üçün launch, async və ya lifecycleScope tətbiq edin.