Coroutine Builder: ما هو، أنواع بناة الكوروتينات وكيفية عملها

ما هو Coroutine Builder؟

Coroutine Builder هي دالة توسعة في Kotlin تأخذ CoroutineScope وكتلة suspend، وتنشئ وتشغل كوروتين جديد. يحدد كل باني كيفية تنفيذ الكوروتين: مع أو بدون إرجاع نتيجة، مع حجب الخيط أو بشكل غير متزامن. البنّاءات هي نقاط الدخول إلى نموذج الكوروتينات في اللغة.

تعمل جميع البنّاءات عبر CoroutineScope، الذي يدير دورة حياة الكوروتينات الفرعية. عند إلغاء النطاق، يتم إلغاء جميع الكوروتينات المشغلة عبره تلقائيًا — هذا هو مبدأ التزامن المنظم. يمنع هذا النهج تسرب الكوروتينات ويضمن إنهاءً قابلًا للتنبؤ.

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 لإدارة دورة حياته. هذا هو الخيار المثالي للعمليات التي تحتاج فقط إلى تأثير جانبي: الحفظ في قاعدة البيانات، إرسال التحليلات، تحديث واجهة المستخدم.

صياغة واستخدام launch

يقبل باني launch CoroutineScope و CoroutineContext اختياري وكتلة suspend. يسمح 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 جميع عمليات دورة الحياة: الإلغاء، انتظار الاكتمال، معالجة الاستثناءات. عند إلغاء النطاق، يتم إلغاء كوروتينات Deferred الفرعية تلقائيًا.

runBlocking: جسر إلى العالم الحاجب

runBlocking هو الباني الوحيد الذي يحجب الخيط الحالي حتى اكتمال الكوروتين. ينشئ CoroutineScope جديد ويشغل الكوروتين المُمرر، محجبًا الخيط المستدعي. يُستخدم في نقاط الدخول main()، في الاختبارات، وعند التكامل مع كود حاجب.

متى يكون runBlocking ضروريًا

runBlocking مبرر في ثلاثة سيناريوهات: نقطة دخول التطبيق (main)، اختبارات الوحدات لدوال suspend، والتكامل مع المكتبات القائمة على الاستدعاءات حيث لا يمكن استخدام suspend. في كود Android الإنتاجي، استخدام runBlocking على الخيط الرئيسي غير موصى به بشدة.

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

للاختبارات، يُوصى باستخدام kotlinx-coroutines-test مع TestCoroutineDispatcher بدلاً من runBlocking — وهذا يوفر التحكم في الوقت ويتجنب الحجب في بيئة الاختبار.

كيفية اختيار الباني المناسب

يعتمد اختيار Coroutine Builder على النتيجة المعادة وسيناريو التنفيذ. إذا كانت العملية لا تتطلب إرجاع بيانات — استخدم launch. إذا كنت بحاجة لنتيجة عملية غير متزامنة — استخدم async. استخدم runBlocking فقط للجسر، واستبدل produce بـ Flow للتدفقات التفاعلية.

توصيات عملية لـ Android

في مشاريع Android التي تستخدم Kotlin Coroutines، الزوج الرئيسي من البنّاءات هما launch و async. يُستخدم launch في ViewModel و UseCases لتشغيل الكوروتينات، بينما يُستخدم async للطلبات المتوازية للشبكة أو قاعدة البيانات. المكتبات الحديثة (Ktor, Room) تدعم بالفعل دوال suspend، مما يقلل الحاجة للاستخدام المباشر لـ async.

• launch — لـ fire-and-forget (تسجيل، تحليلات، تخزين مؤقت)
• async — للطلبات المتوازية مع دمج النتائج
• runBlocking — فقط في main() والاختبارات (ليس على خيط Main في الإنتاج)
• produce — استبدله بـ Flow / SharedFlow / StateFlow