[2] Kotiln Coroutines - Cancelation / TimeOut

https://medium.com/@limgyumin/%EC%BD%94%ED%8B%80%EB%A6%B0-%EC%BD%94%EB%A3%A8%ED%8B%B4%EC%9D%98-%EA%B8%B0%EC%B4%88-cac60d4d621b

도움이 많이 되었다. 

코틀린 코루틴의 기초

 

Dispatcher

 

 

Ref.

Youtube :  [새차원, 코틀린 코루틴] https://youtube.com/playlist?list=PLbJr8hAHHCP5N6Lsot8SAnC28SoxwAU5A

Ref : https://kotlinlang.org/

 

 

 

 

Cancelation

실행 했던 코루틴을 취소 하는 방법 → 취소 하는 것이 중요한 이유는 하나하나 메모리와 리소스를 차지하고 있기 때문

 코루틴 취소의 조건
1) Cancel 호출
2) 코루틴 자체가 취소에 대해 협조적인 상태로 구현되어있어야함.

// 단순 코루틴 취소
// job 객체는 실행되고 있는 코루틴을 취소하게도 해주는 기능을 가지고 있음
fun main() = runBlocking{
    //  이 코루틴은 1000번을 돌면서 0.5초 간격으로 숫자를 출
    val job = launch {
        repeat(1000){
            println("job: I'm sleeping ${it}...")
            delay(500L) //suspend func
        }
    }

    delay(1300L)
    println("main : I'm Tired of waiting")
    job.cancel() // 1.3초 정도 지나면 이 APP 이 끝났으면 좋겠음.
    job.join()
    println("main : Now i can quit.")
}

 

 

/ 코루틴 취소의 조건 - supending functions 은 취소 가능하다.
// suspend 함수를 하나라도 두지 않으면 해당 코루틴은 실행 취소 할 수 없다.
fun main() = runBlocking {
    val startTime = System.currentTimeMillis()
    val job = launch(Dispatchers.Default){
        var nextPrintTime = startTime
        var i = 0
        while(i < 5){
            if (System.currentTimeMillis() >= nextPrintTime){
                 yield() // suspend func : 딜레이를 주지 않고도 종료를 체크 할 수 있음
                // delay(1L)  suspend func 이 반드시
                println("job: I'm sleeping ${i++}...")
                nextPrintTime += 500L
            }
        }
    }
    delay(1300L)
    println("main : I'm tired of waiting")
    job.cancelAndJoin() // cancel 과 join 을 순차적으로 불러주는 함수
    // cancel 되서 일시 중단 함수(yield 나 delay)애서 일시 중단이 되었다가 재개 될때, exception을 던진다.
    println("main : Now i can quit")
}

 

 

 

 

isActive

// 코루틴이 취소 되기 위해서 협조적인 방법을 취하는데 크게 2가지 방법이 있는데 2번째 방법은?
// ( 첫번째 방법은 위에서 봤떤 주기적으로 suspending 호출해라 / 두번째 방법은 명시적으로 상태를 체크 하여 _isActive_로)
// isActive : CourouineScope의 Boolean 값
// exception 을 던지지는 않는다.
fun main() = runBlocking {

    val startTime = System.currentTimeMillis()

    val job = launch(Dispatchers.Default){
        var nextPrintTime = startTime
        var i = 0
        while(isActive){
            if(System.currentTimeMillis() >= nextPrintTime){
                println("job : I'm Sleeping ${i++} ..")
                nextPrintTime +=500L
            }
        }
    }

    delay(1300L)
    println("main : Tired waiting")
    job.cancelAndJoin()
    println("main : Now I can quit")
}

 

 

finally

: 네트워크나 DB 쓰다가 갑자기 코루틴 캔슬 되는 등의 일이 있을 때, 닫아주는 위치

// 코루틴을 종료할 때, 어떻게 리소스를 해제 하여 줄 수 있는가?
// 네트워크나 DB를 쓰다가 갑자기 코루틴 cancel 되면 이 파일을 닫아주고 가야 하는데, 이 닫아주는 위치가 어디인가? 닫아주는 건 finally
fun main() = runBlocking {

    val job = launch(Dispatchers.Default){
       try{
           repeat(1000){
               i -> println("job: I'm sleeping ${i} ...")
               val curTime  = System.currentTimeMillis() // 1970년 1/1일 부터 경과한 시간을 long 값으로 리턴함
               val  timeFormat:SimpleDateFormat =  SimpleDateFormat("yyyy-mm-dd hh:mm:ss")
               val str = timeFormat.format(Date(curTime))
               println(str)
               println(Date(curTime))
               println()
               delay(500L) // 취소에 협조적으로 구현이 되어있음
           }
       }finally {
           // 리소스 해제 지역
           println("job: i'm runnig finally")
       }
    }

    delay(1300L)
    println("main : Tired waiting")
    job.cancelAndJoin() // 일시 중단 되었다가 재개 될 때, exception을 던질 때 finally 블록에서 리소스 해제를 해라.
    println("main : Now I can quit")
}

 

Timeout

// Timeout
// 코루틴이 시작될 때, 이 시간이 지나면 이 코루틴은 취소 된다. 미리 타임 아웃을 지정하는 방식
// withTimeout을 쓰면 TimeoutCancellationException 이 나는데,
// withTimeoutOrNull 이면 Exception났을 때, 결과 값이 null로 떨어짐.

fun main() = runBlocking {
    val result = withTimeoutOrNull(2000L){
        repeat(1000){
            i -> println("i'm sleeping ${i}..")
            delay(500L)
        }
        "Done"
    }
    println("Result is ${result}")
}