async: bu nədir, Deferred və paralel koorutinlər necə işləyir

Kotlin Coroutines-də async nədir?

async — nəticə qaytaran koorutin yaradan CoroutineScope genişləndirmə funksiyasıdır. launch-dan fərqli olaraq, async Deferred<T> — gələcək dəyəri təmsil edən obyekt qaytarır. async vasitəsilə işə salınan koorutin digər koorutinlərlə rəqabətli şəkildə icra olunur, bu da hesablamaları paralelləşdirməyə imkan verir.

async asinxron əməliyyatın nəticəsi sonrakı emal üçün lazım olduqda istifadə olunur: birdən çox mənbədən məlumat yükləmə, kolleksiyaların pəkət emalı, müxtəlif API-lərə paralel sorğular. Deferred dərhal yaradılır və nəticə koorutin başa çatdıqdan sonra əlçatan olur.

import kotlinx.coroutines.*

suspend fun String.delayedValue(): String {
    delay(1000L)
    return this
}

fun main() = runBlocking {
    val deferred: Deferred<String> = async { "Hello".delayedValue() }
    println(deferred.await())
}

async və Deferred sintaksisi

async-in imzası launch-a bənzəyir: eyni CoroutineContext, CoroutineStart parametrləri və suspend-bloku. Fərq qaytarılan tipdədir — Job əvəzinə Deferred<T>, burada T blokun son ifadəsi ilə qaytarılan nəticənin tipidir.

public fun <T> CoroutineScope.async(
    context: CoroutineContext = EmptyCoroutineContext,
    start: CoroutineStart = CoroutineStart.DEFAULT,
    block: suspend CoroutineScope.() -> T
): Deferred<T>

Deferred<T> — Job-dan miras alan və await(), getCompleted(), getCompletionExceptionOrNull() metodlarını əlavə edən interfeysdir. await() suspend-funksiyadır və yalnız koorutin daxilində və ya digər suspend-funksiyada çağırıla bilər. getCompleted() — bloklamayan metoddur, koorutin hələ başa çatmayıbsa istisna atır.

async ilə paralel tapşırıqlar

async-in əsas üstünlüyü tapşırıqları paralel işə salmaq imkanıdır. Ardıcıl gözləmə əvəzinə (ümumi vaxt = vaxtların cəmi), async koorutinləri eyni anda işə salır, ümumi vaxtı ən uzun əməliyyatın vaxtına qədər azaldır.

Paralel məlumat yükləmə

Tipik ssenari — istifadəçi profili, onun parametrləri və sifariş tarixçəsinin üç paralel async sorğusu ilə yüklənməsi. Hər üçü başa çatdıqdan sonra nəticələr vahid məlumat modelində birləşdirilir.

suspend fun loadUserDashboard(userId: String): Dashboard = coroutineScope {
    val profile = async { api.getProfile(userId) }
    val settings = async { api.getSettings(userId) }
    val orders = async { api.getRecentOrders(userId) }

    Dashboard(
        profile = profile.await(),
        settings = settings.await(),
        orders = orders.await()
    )
}

coroutineScope funksiyası alt koorutinləri işə salır və nəticəni qaytarmazdan əvvəl onların başa çatmasını gözləyir. Bütün blok paralel icra olunur, ardıcıl deyil.

Deferred nəticələrinin işlənməsi

Deferred nəticə ilə işləmək üçün bir neçə metodu dəstəkləyir. await() ilə yanaşı, statusu yoxlamaq, hazır dəyəri almaq və Kotlin Coroutines köməkçi funksiyaları vasitəsilə çoxsaylı Deferred-ləri toplamaq üçün metodlar mövcuddur.

Deferred siyahısını toplamaq üçün awaitAll() — kolleksiyadakı bütün Deferred-lər başa çatana qədər icranı dayandıran funksiya istifadə olunur. Əgər ən azı biri səhvlə başa çatıbsa, awaitAll() istisna atır.

suspend fun <T> loadAll(requests: List<suspend () -> T>): List<T> {
    return coroutineScope {
        val deferreds = requests.map { async { it() } }
        deferreds.awaitAll()
    }
}

async və launch arasındakı fərqlər

async və launch arasında seçim koorutinin icra nəticəsinin lazım olub-olmamasından asılıdır. launch Job qaytarır və fire-and-forget əməliyyatları üçün uyğundur, async Deferred qaytarır və məlumat qaytaran tapşırıqlar üçün istifadə olunur. Sintaksis və parametrlər baxımından qurucular eynidir.

• launch → Job (nəticə yoxdur), async → Deferred<T> (nəticə T var)
• launch — fire-and-forget tapşırıqları (loqlama, keşləmə, analitika göndərmə)
• async — paralel hesablamalar (çoxsaylı API-lərdən yükləmə, pəkət emalı)
• Hər ikisi strukturlaşdırılmış paralelliyi və CoroutineStart parametrlərini dəstəkləyir
• await() yalnız Deferred üçün əlçatandır, launch nəticə təmin etmir

Əhəmiyyətli qayda: fire-and-forget üçün async istifadə etməyin. Koorutinin nəticəsi lazım deyilsə, launch istifadə edin. async Deferred yaratmaq üçün əlavə yük yaradır ki, bu da belə ssenaridə əsaslandırılmır.

Mobil inkişafda async nümunələri

Android-də async ViewModel və UseCases daxilində paralel əməliyyatlar üçün istifadə olunur. Tipik ssenarilər: profil və xəbər lentinin eyni vaxtda yüklənməsi, bir neçə hava xidmətindən hava məlumatının alınması, serverlə pəkət məlumat sinxronizasiyası.

class HomeViewModel : ViewModel() {
    fun loadHomeScreen() {
        viewModelScope.launch {
            val userData = async(Dispatchers.IO) { repository.getUserData() }
            val newsFeed = async(Dispatchers.IO) { repository.getNewsFeed() }
            val notifications = async(Dispatchers.IO) { repository.getNotifications() }

            val state = HomeState(
                user = userData.await(),
                news = newsFeed.await(),
                unread = notifications.await()
            )
            _uiState.update { state }
        }
    }
}

Xətaların izolyasiyası üçün async qrupunu coroutineScope və ya supervisorScope ilə bükmək tövsiyə olunur. supervisorScope bir async-də səhv olsa belə, qalan async koorutinlərinin icrasını davam etdirməyə imkan verir — bu kritik olmayan əməliyyatlar üçün faydalıdır.