runBlocking — এটি কি, ব্লকিং ব্রিজ ও কিভাবে কাজ করে

runBlocking কি?

runBlocking হল একটি Kotlin ফাংশন যা একটি নতুন CoroutineScope তৈরি করে এবং পাস করা কোরুটিন চালু করে, বর্তমান থ্রেডকে সম্পূর্ণ শেষ হতে ব্লক করে। অন্য সকল Coroutine Builder এর বিপরীতে, runBlocking একটি suspend ফাংশন নয় এবং সাধারণ সিঙ্ক্রোনাস কোড থেকে ডাকা যেতে পারে। runBlocking এর সিগনিচার CoroutineContext এবং একটি suspend ব্লক নেয়, T টাইপের একটি ফলাফল ফেরত দেয়।

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

runBlocking বর্তমান থ্রেডে একটি নতুন event-loop শুরু করে। যখন কোরুটিন একটি suspend ফাংশন (যেমন delay() বা await()) কল করে, runBlocking থ্রেডকে ব্লক করে এবং স্থগিত কোরুটিনটি পুনরায় শুরু হতে একই থ্রেডে অন্য নির্ধারিত কোরুটিন চালায়। এটি সহযোগিতামূলক ব্লকিং — থ্রেডটি নিষ্ক্রিয় থাকে না বরং অন্য কোরুটিন প্রক্রিয়া করে।

কিভাবে runBlocking কাজ করে

runBlocking এর অন্তর্গত প্রক্রিয়া event-loop এর উপর ভিত্তি করে: যখন একটি suspend ফাংশন ডাকা হয়, runBlocking বর্তমান ব্লকের মানাগুল বন্ধ করে এবং ক্য়ূ থেকে অন্য কোরুটিন চালায়। যখন suspend ফাংশন শেষ হয়, মানাগুল পুনরায় শুরু হয়। এই চক্র তবে থেকে যায় যত্না সকল কোরুটিন শেষ না হয়।

Event-loop এর অন্তর্নিহিত

runBlocking কোরুটিন চালানোর জন্য নিজস্ব একক-থ্রেড পুল ব্যবহার করে। Dispatchers.IO বা Default এর বিপরীতে, runBlocking থ্রেড পরিবর্তন করে না — এটি সকল কোরুটিন বর্তমান থ্রেডে পরিচালনা করে, তাদের এক্সিকিউশন ইন্টারলেভ করে। এটি একমাত্র বিল্ডার যা একই থ্রেডে মানাগুলের গারন্টি দেয়।

fun main() {
    val threadName = Thread.currentThread().getName()
    println("runBlocking আগে $threadName এ")

    val result = runBlocking {
        println("runBlocking এর মধ্যে ${Thread.currentThread().getName()} এ")
        delay(500L)
        "Done"
    }

    println("runBlocking এর পরে: $result")
}

আউটপুট দেখাবে যে সকল তিনটি println বিবরণ একই থ্রেডে করা হয়। runBlocking থ্রেড পরিবর্তন করে না বরং event-loop ব্যবহার করে একই থ্রেডের মধ্যে সহযোগিতামূলক মাল্টিটাস্কিং সংগঠিত করে।

কথায় runBlocking ব্যবহার করবেন

runBlocking তিনটি পরিস্থিতিতে যুক্তিযুক্ত: কনসোল অ্যাপ্লিকেশনে main() প্রবেশ বিন্দু, suspend ফাংশনের ইউনিট টেস্ট এবং সেতু — callback-ভিত্তিক বা blocking লাইব্রেরি থেকে suspend কোড ডাকা। প্রোডাক্শন Android কোডে, প্রধান থ্রেডে এটি ব্যবহার করা কঠোরভাবে নিষিদ্ধ।

Android টেস্টের জন্য, runBlocking এর পরিবর্তে kotlinx-coroutines-test এর TestDispatcher ব্যবহার করুন। এটি সময় নিয়ন্ত্রণ, স্বচালিত পরিষ্কার এবং টেস্ট বিচ্ছিন্নতা প্রদান করে।

runBlocking এর বিকল্প

অধিকাংশ পরিস্থিতিতে, runBlocking কে অ্যাসিঙ্ক্রোনাস বিকল্প দিয়ে প্রতিস্থাপিত করা যেতে পারে এবং উচিত। Android এর জন্য, এগুলো হল viewModelScope, lifecycleScope বা উপযুক্ত ডিস্প্যাচার সহ CoroutineScope। টেস্টের জন্য — TestCoroutineDispatcher এবং runTest।

    // খারাপ: Android প্রধান থ্রেডে runBlocking
runBlocking(Dispatchers.Main) {
    val result = networkApi.fetchData()
    textView.setText(result)
}

// ভালো: lifecycleScope
lifecycleScope.launch {
    val result = withContext(Dispatchers.IO) { networkApi.fetchData() }
    textView.setText(result)
}

টেস্টের জন্য, বিকল্প হল kotlinx-coroutines-test এর runTest। এটি ভিরতুয়াল সময় সহ TestCoroutineScope তৈরি করে, যা বাস্তবিক অপেক্ষা ছাড়াই বিলম্ব পরীক্ষা করতে দেয়। এটি টেস্টগুলিকে দ্রুত করে এবং নির্দেশ্যক করে।

runBlocking ব্যবহারের উদাহরণ

সবচেয়ে সাধারণ পরিস্থিতি হল suspend ফাংশন পরীক্ষা করা। টেস্টে runBlocking আপনাকে আর্কিটেকচার পরিবর্তন ছাড়াই একটি কোরুটিন ফলাফলের জন্য সিঙ্ক্রোনাসলি অপেক্ষা করতে দেয়। দ্বিতীয় পরিস্থিতি হল callback API সহ লাইব্রেরি, যেখানে runBlocking এর মাধ্যমে suspend ফাংশনগুলি blocking প্রসঙ্গ থেকে ডাকা হয়।

// runBlocking এর সাথে suspend ফাংশন পরীক্ষা
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 এবং suspend দুনিয়ার মধ্যে সেতু নির্মাণের জন্য, callbacks এর পরিবর্তে runBlocking এর সঙ্গে CompletableDeferred ব্যবহার করুন — এটি অ্যাসিঙ্ক্রোনাস অপারেশন চেইনকে সরল করে এবং কোড পঠনিয়তা বাড়ায়।

ভুল ব্যবহারের বিপদ

runBlocking এর অনুচিত ব্যবহার ব্লকিং পদ্ধতি থেকে কোরুটিনে স্থানান্তরণ করার সময় সাধারণ ভুলগুলির একটি। প্রধান সমস্যাগুলি: Android এর প্রধান থ্রেডে কল করা, runBlocking কে একে অন্যের মধ্যে নেস্ট করা, অ্যাসিঙ্ক্রোনাস ফাংশনের মধ্যে ব্যবহার করা এবং runBlocking এর মাধ্যমে দীর্ঘ অপারেশন চালু করা।

• ANR — Android এর প্রধান থ্রেডে runBlocking UI রেন্ডারিং 5 সেকেন্ডের বেশি জন্য ব্লক করে
• ডেডলক — একই থ্রেডে একটি কোরুটিনের মধ্যে নেস্টেড runBlocking পারস্পরিক ব্লকিং সৃষ্টি করে
• ডিস্প্যাচার দিব্যন্তি — ব্যাকগ্রাউন্ড থ্রেডে runBlocking এর মধ্যে Dispatchers.Main এর কোন Looper নেই এবং এক্সেপশন ছুড়ে দেয়
• মেমোরি লিক — Activity/Fragment ধ্বংস হলে runBlocking স্বচালিতভাবে বাতিল হয় না

সুবর্ণ নিয়ম: runBlocking একটি সেতু, প্রতিস্থাপন নয়। এটি শুধুমাত্র blocking এবং non-blocking দুনিয়াকে সংযুক্ত করতে ব্যবহার করুন। অন্য সকল কাজের জন্য, launch, async বা lifecycleScope ব্যবহার করুন।