许昌市建设局网站中国临海建设规划局网站

背景

在项目实践过程中，笔者发现很多异步或者耗时的操作，都使用了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).performanceCountval currentWeekCount = teacherPerformanceServiceApi.getTeachersCurrentWeekPerformanceCountByByRangeTime(it).performanceCountWildSchoolData(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.schoolIdthis.userId = pagePointVo.userIdthis.userRole = pagePointVo.userRolethis.moduleKey = pagePointVo.moduleKeythis.eventId = pagePointVo.eventIdthis.clickTime = Date()}pagePointMapper.insert(pagePoint)}// 其他操作}