[Android] Coroutine 코루틴 예제1

Basic

SecondFragment.kt

binding.checkBtn.setOnClickListener {
    secondViewModel.exampleSuspend()
}

 

SecondViewModel.kt

fun exampleSuspend() = runBlocking {
    
    launch {
        repeat(5) { i ->
            println("Coroutine A, $i")
        }
    }
    
    launch {
        repeat(5) { i ->
            println("Coroutine B, $i")
        }
    }

    println("Coroutine Outer")
}

I: Coroutine Outer
I: Coroutine A, 0
I: Coroutine A, 1
I: Coroutine A, 2
I: Coroutine A, 3
I: Coroutine A, 4
I: Coroutine B, 0
I: Coroutine B, 1
I: Coroutine B, 2
I: Coroutine B, 3
I: Coroutine B, 4

launch 가 먼저 실행되서 Coroutine A 가 가장 먼저 찍힐 것 같았지만,

launch는 코루틴이 실행되기 위해 스케쥴링이 된다는 것을 예상할 수 있다.

→ Coroutine Outer 먼저 찍히고 launch 로 생성된 코루틴이 순서대로 실행된다. 

 

---

Cancellation and Timeouts

→ 코루틴을 취소 되기 위해서는, 코루틴이 협조적이어야 함

방법 1. suspend 함수를 수행하는 job.cancleAndJoin()

방법 2. 일반 함수 일때는 중단이 안됨 → isActive 상태 체크하여 코루틴 취소하기

fun exampleSuspend() = runBlocking {

        val job = launch {
            repeat(10) { i ->
                println("job: I'm sleeping $i...")
                delay(1000L)
            }
        }

        delay (1500L)
        println("main: I'm tired of waiting!")
//        job.cancel() // 코루틴 종료
//        job.join() // job 수행이 끝나기를 기다린다
        job.cancelAndJoin()
        println("main: Now I can quit")
    }

I: job: I'm sleeping 0...
I: job: I'm sleeping 1...
I: main: I'm tired of waiting!
I: main: Now I can quit

 

리소스 해제 위치

fun exampleSuspend() = runBlocking {

        val job = launch {
            try {
                repeat(100) { i ->
                    println("job: I'm sleeping $i...")
                    delay(1000L) // suspend 함수이기 때문에, 이 코루틴은 취소하기에 협조적인 형태
                }
            } finally {
                // 코루틴을 취소하면, suspend 함수가 재개되면서 exception 을 던짐
                // 이곳에서 리소스 해제
                println("job: I'm running finally")
            }
        }

        delay (1500L)
        println("main: I'm tired of waiting!")
//        job.cancel() // 코루틴 종료
//        job.join() // job 수행이 끝나기를 기다린다
        job.cancelAndJoin()
    }

I: job: I'm sleeping 0...
I: job: I'm sleeping 1...
I: main: I'm tired of waiting!
I: job: I'm running finally

 

Timeouts

fun exampleSuspend() = runBlocking {
    val result = withTimeoutOrNull(1300L) {
        repeat(10) { i ->
            println("I'm sleeping $i ...")
            delay(500L)
        }
        "Done"
    }
    println("Result is $result")
}

I: I'm sleeping 0 ...
I: I'm sleeping 1 ...
I: I'm sleeping 2 ...
I: Result is null