Coroutine Builder: چیست، انواع سازنده‌های کوروتین و چگونه کار می‌کنند

Coroutine Builder چیست؟

Coroutine Builder — تابع توسعه‌ای Kotlin است که CoroutineScope و suspend-block را می‌پذیرد و یک کوروتین جدید ایجاد و اجرا می‌کند. هر سازنده تعیین می‌کند که کوروتین چگونه اجرا شود: با بازگشت نتیجه یا بدون آن، با مسدود کردن رشته یا به صورت ناهمگام. سازنده‌ها نقاط ورود به مدل کوروتین در زبان هستند.

همه سازنده‌ها از طریق CoroutineScope کار می‌کنند که چرخه عمر کوروتین‌های فرزند را مدیریت می‌کند. هنگام لغو scope، تمام کوروتین‌های اجرا شده از طریق آن به طور خودکار لغو می‌شوند — این اصل همزمانی ساختاریافته است. این رویکرد از نشت کوروتین‌ها جلوگیری می‌کند و پایان‌پذیری قابل پیش‌بینی را تضمین می‌کند.

import kotlinx.coroutines.*

fun main() = runBlocking {
    // سازنده‌ها در داخل CoroutineScope کار می‌کنند
    val job = launch {
        delay(1000L)
        println("جهان!")
    }
    println("سلام،")
    job.join()
}

انواع اصلی سازنده‌های کوروتین

Kotlin چهار سازنده داخلی کوروتین ارائه می‌دهد: launch، async، runBlocking و produce. هر کدام نوع بازگشتی و حوزه کاربرد خود را دارند. برای توسعه موبایل Android، اصلی‌ترین آنها launch و async هستند — آنها به صورت غیرمسدودکننده کار می‌کنند و با اجزای معماری ادغام می‌شوند.

هر سازنده پارامترهای اضافی می‌پذیرد: CoroutineStart (استراتژی اجرا)، CoroutineContext (توزیع‌کننده، استثناها) و بلوک کد نام‌گذاری شده. به طور پیش‌فرض کوروتین بلافاصله اجرا می‌شود (CoroutineStart.DEFAULT).

launch: اجرای fire-and-forget

launch — پرکاربردترین سازنده در توسعه Android است. کوروتینی را اجرا می‌کند که نتیجه برنمی‌گرداند و شی Job را برای مدیریت چرخه عمر آن برمی‌گرداند. این انتخاب ایده‌آل برای عملیاتی است که فقط به اثر جانبی نیاز دارند: ذخیره در پایگاه داده، ارسال تحلیل، به‌روزرسانی UI.

سینتکس و استفاده از launch

سازنده launch CoroutineScope، CoroutineContext اختیاری و suspend-block را می‌پذیرد. Job بازگشتی به شما اجازه می‌دهد کوروتین را لغو کنید، منتظر اتمام آن بمانید یا وضعیت آن را بررسی کنید.

val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
val job: Job = scope.launch(CoroutineStart.LAZY) {
    val data = fetchFromNetwork()
    saveToDatabase(data)
}
job.start()
job.join()

پارامتر CoroutineStart.LAZY اجرا را تا فراخوانی صریح start() یا join() به تأخیر می‌اندازد. این برای مقداردهی اولیه تأخیری و اجرای شرطی مفید است. برای اجرای فوری استاندارد از CoroutineStart.DEFAULT استفاده می‌شود یا پارامتر حذف می‌گردد.

async: محاسبات موازی با نتیجه

async — سازنده‌ای که Deferred<T> را برمی‌گرداند — وعده ناهمگام نتیجه. فراخوانی await() کوروتین را تا دریافت نتیجه متوقف می‌کند، بدون اینکه رشته را مسدود کند. این مکانیزم اصلی برای وظایف موازی در کوروتین‌های Kotlin است.

اجرای دو درخواست به صورت موازی

async به ویژه زمانی مؤثر است که نیاز به انجام چندین عملیات مستقل به طور همزمان باشد. برخلاف فراخوانی ترتیبی توابع suspend، async کوروتین‌ها را به صورت موازی اجرا می‌کند و زمان کل اجرا را کاهش می‌دهد.

suspend fun fetchUserData(): UserData {
    val deferred1 = CoroutineScope(Dispatchers.IO).async { api.getProfile() }
    val deferred2 = CoroutineScope(Dispatchers.IO).async { api.getSettings() }
    val deferred3 = CoroutineScope(Dispatchers.IO).async { api.getNotifications() }
    return UserData(
        profile = deferred1.await(),
        settings = deferred2.await(),
        notifications = deferred3.await()
    )
}

Deferred از Job ارث‌بری می‌کند، بنابراین async از تمام عملیات چرخه عمر پشتیبانی می‌کند: لغو، انتظار برای اتمام، مدیریت استثناها. هنگام لغو scope، کوروتین‌های فرزند Deferred به طور خودکار لغو می‌شوند.

runBlocking: پل به دنیای blocking

runBlocking — تنها سازنده‌ای است که رشته جاری را تا پایان کوروتین مسدود می‌کند. CoroutineScope جدیدی ایجاد می‌کند و کوروتین ارسال شده را اجرا می‌کند و رشته فراخوان را مسدود می‌کند. در نقاط ورود main()، در تست‌ها و در ادغام با کد blocking استفاده می‌شود.

چه زمانی runBlocking ضروری است

runBlocking در سه سناریو توجیه می‌شود: نقطه ورود برنامه (main)، تست‌های واحد توابع suspend و ادغام با کتابخانه‌های callback-based که در آنها نمی‌توان از suspend استفاده کرد. در کد تولید Android، استفاده از runBlocking در رشته اصلی قطعاً توصیه نمی‌شود.

class CoroutineTest {
    @Test
    fun `test suspend function`() = runBlocking {
        val result = mySuspendFunction()
        assertEquals("expected", result)
    }
}

برای تست‌ها توصیه می‌شود به جای runBlocking از kotlinx-coroutines-test با TestCoroutineDispatcher استفاده کنید — این کنترل زمان را فراهم می‌کند و از قفل‌شدگی در محیط تست جلوگیری می‌کند.

چگونه سازنده مناسب را انتخاب کنیم

انتخاب Coroutine Builder به نتیجه بازگشتی و سناریوی اجرا بستگی دارد. اگر عملیات نیاز به بازگشت داده ندارد — از launch استفاده کنید. اگر نتیجه عملیات ناهمگام مورد نیاز است — async. runBlocking را فقط برای bridging به کار ببرید و produce را برای جریان‌های واکنشی با Flow جایگزین کنید.

توصیه‌های عملی برای Android

در پروژه‌های Android با Kotlin Coroutines، جفت اصلی سازنده‌ها launch و async هستند. launch در ViewModel و UseCases برای اجرای کوروتین‌ها استفاده می‌شود و async — برای درخواست‌های موازی به شبکه یا پایگاه داده. کتابخانه‌های مدرن (Ktor, Room) قبلاً از توابع suspend پشتیبانی می‌کنند که نیاز به استفاده مستقیم از async را به حداقل می‌رساند.

• launch — برای fire-and-forget (ثبت رویداد، تحلیل، ذخیره‌سازی موقت)
• async — برای درخواست‌های موازی با ترکیب نتایج
• runBlocking — فقط در main() و تست‌ها (نه در production روی Main-thread)
• produce — با Flow / SharedFlow / StateFlow جایگزین کنید