【2023】Kotlin教程第三篇 Kotlin进阶第19章协程 19.5 管理协程 19.5.3 取消协程

红太狼 2024-03-23 11:27 10阅读 0赞

### 【2023】Kotlin教程 ###

#### 文章目录 ####

*   *  【2023】Kotlin教程
     *   *  第三篇 Kotlin进阶
         *  第19章 协程
         *   *  19.5 管理协程
             *   *  19.5.3 取消协程

![在这里插入图片描述][7cb3efd38c564acd96ba7e70db5a49eb.png_pic_center]

#### 第三篇 Kotlin进阶 ####

#### 第19章 协程 ####

协程与线程类似都可以处理并发任务。协程在很多语言中都支持，但Java没有协程支持，Kotlin支持协程编程。本章介绍协程。

##### 19.5 管理协程 #####

管理协程是比管理线程简单多了，本节介绍几个管理协程的常用函数。

###### 19.5.3 取消协程 ######

协程体结束，协程进入完成状态，协程就停止了。但是有些业务比较复杂，例如想开发一个下载程序，每隔一段执行一次下载任务，下载任务一般会在由子协程执行的，挂起一段时间再执行。这个下载子协程中会有一个死循环，但是为了能够停止子协程，可以调用cancel函数或cancelAndJoin函数取消协程。

示例代码如下：

package com.dingjiaxiong
    
    import kotlinx.coroutines.cancelAndJoin
    import kotlinx.coroutines.delay
    import kotlinx.coroutines.launch
    import kotlinx.coroutines.runBlocking
    
    /**
     * @Projectname: Hello
     * @Classname: `ch19.5.3`
     * @Author: Ding Jiaxiong
     * @Data:2023/4/4 16:51
     */
    
    fun main() = runBlocking<Unit> {
        
    
        // 创建协程
        val job = launch {
        
            // 一直循环, 直到满足条件再取消协程
            while (true) {
        
    
                // 协程开始工作
                println("下载中...")
                delay(10000L)
            }
        }
    
        val command = readLine() // 从键盘读取字符串
        if (command == "exit") {
        
            job.cancel() // 取消协程
            job.join() // 等待协程结束
    
    //        job.cancelAndJoin() // 两个函数的合体
        }
    }

【有一说一，这代码有问题啊，readLine() 会卡在那儿等待用户输入，而且只有一次，离谱。】

笔者重新写一个，主协程歇5S后，将子协程挂掉

package com.dingjiaxiong
    
    import kotlinx.coroutines.cancelAndJoin
    import kotlinx.coroutines.delay
    import kotlinx.coroutines.launch
    import kotlinx.coroutines.runBlocking
    
    /**
     * @Projectname: Hello
     * @Classname: `ch19.5.3`
     * @Author: Ding Jiaxiong
     * @Data:2023/4/4 16:51
     */
    
    fun main() = runBlocking<Unit> {
        
    
        // 创建协程
        val job = launch {
        
            // 一直循环, 直到满足条件再取消协程
            while (true) {
        
    
                // 协程开始工作
                println("下载中...")
                delay(1000L)
            }
        }
    
        delay(5000L)
        job.cancel() // 取消协程
        job.join() // 等待协程结束
    
    //        job.cancelAndJoin() // 两个函数的合体
    
    }

运行结果

![在这里插入图片描述][30893728884f485cafb9f4b9f494f36f.png_pic_center]

没毛病。

取消协程往往需要调用join等待job协程结束，否则可能会出现job还没有结束，主协程已经结束的情况。

[7cb3efd38c564acd96ba7e70db5a49eb.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/1f6f8bde8a624593a7df2debd3ea3739.png
[30893728884f485cafb9f4b9f494f36f.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/23/45a2d3267c4d427fa9456faaca8b5707.png