协程取消与异常处理

协程（2）

当我们需要取消协程时，我们可以通过对launch的返回值Job对象执行cancel()方法来取消协程。
但是当协程中正在执行计算相关的事件时，协程将不会被取消，而是会执行下去。因此即便取消了协程，任然要添加一个join()方法，避免协程没有正确取消和结束，而直接执行后面的操作。有一个简单的方法即cancelAndjoin()可以直接结合两个方法，取消并阻塞。
例如:

import kotlinx.coroutines.*

fun main() = runBlocking {
    //sampleStart
    val startTime = System.currentTimeMillis()
    val job = launch(Dispatchers.Default) {
        var nextPrintTime = startTime
        var i = 0
        while (i < 5) { // computation loop, just wastes CPU
            // print a message twice a second
            if (System.currentTimeMillis() >= nextPrintTime) {
                println("job: I'm sleeping ${i++} ...")
                nextPrintTime += 500L
            }
        }
    }
    delay(1300L) // delay a bit
    println("main: I'm tired of waiting!")
    job.cancelAndJoin() // cancels the job and waits for its completion
    println("main: Now I can quit.")
    //sampleEnd    
}

在上述例程中，协程便没有正确取消。但是你依然可以join等他结束后再执行最后一句话。

使计算代码也能取消

再协程中有个属性isActive当协程任然在继续时，他变为true，当他被外界取消时，他便变为false，因此你可以通过他来关掉计算的过程，如下：

import kotlinx.coroutines.*

fun main() = runBlocking {
    //sampleStart
    val startTime = System.currentTimeMillis()
    val job = launch(Dispatchers.Default) {
        var nextPrintTime = startTime
        var i = 0
        while (isActive) { // cancellable computation loop
            // print a message twice a second
            if (System.currentTimeMillis() >= nextPrintTime) {
                println("job: I'm sleeping ${i++} ...")
                nextPrintTime += 500L
            }
        }
    }
    delay(1300L) // delay a bit
    println("main: I'm tired of waiting!")
    job.cancelAndJoin() // cancels the job and waits for its completion
    println("main: Now I can quit.")
    //sampleEnd    
}

finally

在协程中，你同样可以使用try{}finally{}来实现取消协程时的回收操作。finally中的函数一定会实现。你甚至可以在finally中再调用一次协程，那并没有问题。通过withContext()方法

import kotlinx.coroutines.*

fun main() = runBlocking {
    //sampleStart
    val job = launch {
        try {
            repeat(1000) { i ->
                println("job: I'm sleeping $i ...")
                delay(500L)
            }
        } finally {
            withContext(NonCancellable) {
                println("job: I'm running finally")
                delay(1000L)
                println("job: And I've just delayed for 1 sec because I'm non-cancellable")
            }
        }
    }
    delay(1300L) // delay a bit
    println("main: I'm tired of waiting!")
    job.cancelAndJoin() // cancels the job and waits for its completion
    println("main: Now I can quit.")
    //sampleEnd    
}

超时

通过设置withTimeout来使超过时间的协程强行退出。
这种设置会导致抛出异常

import kotlinx.coroutines.*

fun main() = runBlocking {
    //sampleStart
    withTimeout(1300L) {
        repeat(1000) { i ->
            println("I'm sleeping $i ...")
            delay(500L)
        }
    }
    //sampleEnd
}