迹忆客 专注技术分享

Kotlin runBlocking() 函数是一个阻塞主线程的挂起函数。 它有助于在同步代码和异步代码之间架起一座桥梁。

在本文中，我们将了解 Kotlin runBlocking() 及其在不同场景中的使用。

Kotlin 中的 runBlocking 函数

您可能听说过 Kotlin 中的 delay() 函数。 delay() 函数暂停协程并将其延迟特定时间。

但是，它不会阻塞整个线程。 这意味着当我们使用 delay() 函数时，我们仍然可以执行其他操作，例如在 UI 中进行更改。

另一方面，runBlocking() 函数会阻塞整个线程，直到它完成。 因此，在带有 runBlocking() 代码的线程完成之前，编译器不会执行任何其他操作。

Kotlin runBlocking() 函数启动的新线程是从主线程启动的。

为了理解这一点，让我们看两个示例代码。 在第一段代码中，我们将在 GlobalScope.launch() 中使用 delay() 函数。 在第二个示例中，我们将在 Kotlin runBlocking() 函数中使用它。

在 GlobalScope.launch() 中使用 delay()

package com.example.mycoroutines

import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import android.widget.Toast
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch

class MainActivity : AppCompatActivity() {
    val TAG:String="This is Main Activity"
    override fun myFunc(savedInstanceState: Bundle?) {
        super.myFunc(savedInstanceState)
        setContentView(R.layout.activity_main)
        GlobalScope.launch(Dispatchers.Main) {
            delay(5000)
            Log.d(TAG,"Global Scope")
            Toast.makeText(applicationContext,"Thread executed in global scope",Toast.LENGTH_SHORT).show()
        }
        Log.d(TAG,"Not Global Scope")
        Toast.makeText(applicationContext,"Thread executed is not in Global Scope",Toast.LENGTH_SHORT).show()
    }
}

当您在 Android Studio 中运行此类代码时，将执行标签“Not Global Scope”。 然后延迟 5 秒执行标签“Global Scope”消息。

这意味着只有延迟，但仍会执行操作。 因此，线程没有完全阻塞。

在 Kotlin runBlocking() 中使用 delay()

如前所述，当我们在 GlobalScope.launch() 中使用 delay() 函数时，整个线程并没有被阻塞。

但是当我们在 Kotlin runBlocking 中使用它时，线程会被阻塞，直到执行完 runBlocking 代码中的所有函数。 这里有一个例子来证明这一点。

package com.example.mycoroutines

import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import android.widget.Toast
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch

class MainActivity : AppCompatActivity() {
    val TAG:String="This is Main Activity"
    override fun myFunc(savedInstanceState: Bundle?) {
        super.myFunc(savedInstanceState)
        setContentView(R.layout.activity_main)
        Log.d(TAG, "Prior using run blocking")
            runBlocking 
              {
              Log.d(TAG,"Entered run-blocking")
              delay(3000)

              Log.d(TAG,"Run-blocking started")
              Log.d(TAG,"Run-blocking ended")
            }
        Log.d(TAG,"Post using run blocking")
    }
}

当我们使用这段代码时，最后执行标签“Post using run blocking”。 原因是所有的执行都停止了，直到整个 runBlocking 代码被执行完。