【Kotlin 】协程

2024-01-01 10:44:06

背景

在项目实践过程中,笔者发现很多异步或者耗时的操作,都使用了Kotlin中的协程,所以特地研究了一番。

定义

关于协程(Coroutine),其实更多的应该是一种并发设计模式。与传统的线程或进程相比,协程更加轻量级,因为它运行在线程之上,在执行过程中可以主动地暂停,并在需要时恢复执行。而且这些切换操作是在操作系统中的用户态完成的。

实践

  • 引入maven依赖:
<dependency>
	<groupId>org.jetbrains.kotlinx</groupId>
	<artifactId>kotlinx-coroutines-core</artifactId>
</dependency>
  • 两种启动模式
    • runBlocking
    • GlobalScope.launch

GlobalScope.launch

GlobalScope.launch 中启动的协程不会阻塞主线程。主线程会继续执行,而协程会在后台执行。在上述例子中,为了演示效果,使用了 Thread.sleep(2000) 来模拟等待协程执行。
其中,launch 是一个函数,用于创建协程并将其函数主体的执行分派给相应的调度程序。

fun main() {
    // 启动协程
    GlobalScope.launch {
        delay(2000) // 挂起协程,模拟异步操作
        println("World!")
    }

    println("Hello,")
    Thread.sleep(4000) // 阻塞主线程,等待协程执行完毕
}

runBlocking

runBlocking 中启动的协程会阻塞当前线程,直到所有启动的协程都执行完毕。

fun main() = runBlocking {
    // 在 runBlocking 作用域内启动协程
    launch {
        // 协程代码
        println("Inside coroutine")
    }

    // 主线程继续执行
    println("Outside coroutine")

    // 阻塞主线程,等待协程执行完毕
}

业务实践

  • Dispatchers.IO Kotlin提供的协程调度方式,指示此协程应在为 I/O 操作预留的线程上执行,适合在主线程之外执行磁盘或网络 I/O。
  • Dispatchers.Main 使用此调度程序可在主线程上运行协程。(在官方文档介绍中,主要用于安卓开发中,与界面交互和执行快速工作。)
  • Dispatchers.Default 适合在主线程之外执行占用大量 CPU 资源的工作。
private fun sendRefundHttpPost(weChatPayRefundUrl: String, xmlRequestData: String): Map<String, String> = runBlocking {
      // 启用协程发送退款操作
        return@runBlocking withContext(Dispatchers.IO) {
            val responseXmlStr = careWeChatHttps.postXmlForString(weChatPayRefundUrl, xmlRequestData)
            WXPayUtil.xmlToMap(responseXmlStr)
        }
    }
 private fun getSchoolDate(allTeacherIds: Set<String>): WildSchoolData = runBlocking {
       // 涉及统计的allTeacherIds 数量比较大, 创建异步任务去操作
        val elements = allTeacherIds.chunked(60).map {
            async(Dispatchers.Default) {
                val totalCount = teacherPerformanceServiceApi.getTeachersTotalPerformanceCount(it).performanceCount
                val currentWeekCount = teacherPerformanceServiceApi.getTeachersCurrentWeekPerformanceCountByByRangeTime(it).performanceCount
                WildSchoolData(totalCount, currentWeekCount)
            }
        }
        // 调用await等待异步任务结束
        return@runBlocking WildSchoolData(elements.awaitAll().sumBy { it.totalCount }, elements.awaitAll().sumBy { it.currentWeekCount })
    }

    fun savePoint(pagePointVo: PagePointVo): Any {
       // 启用协程执行一个操作流水的插入, 不影响其他操作
        GlobalScope.launch(context = Dispatchers.IO) {
            val pagePoint = PagePoint().apply {
                this.schoolId = pagePointVo.schoolId
                this.userId = pagePointVo.userId
                this.userRole = pagePointVo.userRole
                this.moduleKey = pagePointVo.moduleKey
                this.eventId = pagePointVo.eventId
                this.clickTime = Date()
            }
            pagePointMapper.insert(pagePoint)
        }
        // 其他操作
    }

文章来源:https://blog.csdn.net/legendaryhaha/article/details/135322578
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。