⚡ Coroutines Basics

🎯 Mục tiêu: Hiểu Coroutines - cách xử lý async/concurrent programming trong Kotlin.

---

💡 Khái niệm

Coroutines là light-weight threads cho phép viết async code như sync code.

import kotlinx.coroutines.*

fun main() = runBlocking {
    launch {
        delay(1000)
        println("World!")
    }
    println("Hello,")
}
// Output: Hello, (wait 1s) World!

---

📝 Suspend Functions

suspend fun fetchUser(): User {
    delay(1000)  // Giả lập network call
    return User("Alice", 25)
}

fun main() = runBlocking {
    val user = fetchUser()  // Chờ 1s
    println(user)
}

---

🔧 Coroutine Builders

// runBlocking - block thread, chờ hoàn thành
fun main() = runBlocking {
    // code
}

// launch - fire and forget, trả về Job
val job = launch {
    delay(1000)
    println("Done")
}
job.join()  // Chờ hoàn thành

// async - trả về Deferred với kết quả
val deferred = async {
    delay(1000)
    "Result"
}
val result = deferred.await()  // Chờ và lấy kết quả

---

🎯 Structured Concurrency

suspend fun loadData() = coroutineScope {
    val users = async { fetchUsers() }
    val posts = async { fetchPosts() }

    // Cả 2 chạy song song
    println("Users: ${users.await()}")
    println("Posts: ${posts.await()}")
}

---

📦 Dispatchers

// Main - UI thread (Android)
withContext(Dispatchers.Main) {
    updateUI()
}

// IO - cho network, file
withContext(Dispatchers.IO) {
    fetchFromNetwork()
}

// Default - CPU intensive
withContext(Dispatchers.Default) {
    heavyComputation()
}

---

📱 Trong Android

class UserViewModel : ViewModel() {

    fun loadUser() {
        viewModelScope.launch {
            _state.value = UiState.Loading

            try {
                val user = withContext(Dispatchers.IO) {
                    repository.fetchUser()
                }
                _state.value = UiState.Success(user)
            } catch (e: Exception) {
                _state.value = UiState.Error(e)
            }
        }
    }
}

---

⚠️ Cancellation

val job = launch {
    repeat(1000) { i ->
        println("Iteration $i")
        delay(500)
    }
}

delay(2000)
job.cancel()  // Cancel sau 2 giây

---

✅ Checklist

• Hiểu suspend functions
• Sử dụng launch, async, runBlocking
• Hiểu Dispatchers: Main, IO, Default
• Sử dụng withContext để đổi dispatcher
• Cancel coroutines đúng cách

---

Kết thúc khóa học Ngôn ngữ Kotlin!

Tiếp theo: Kotlin Coroutines chuyên sâu | Android Development