Kotlin 任务调度器：概述与使用示例

Kotlin 任务调度器：完整指南

任务调度器 (Task Scheduler) 是一个强大的工具，允许您在指定时间或按指定频率自动执行特定操作。在 Kotlin 语言中，它被广泛用于开发服务器端应用、Android 应用甚至脚本，有几种实现任务调度器的方法。在本文中，我们将详细介绍主要方法、它们的优势，并提供实用的代码示例。

为什么需要任务调度器？

任务调度器解决了开发中的许多典型问题：

• 自动发送通知（电子邮件、推送通知）按计划进行。
• 清理临时数据（缓存、用户会话）每天一次。
• 定期同步与外部 API 或数据库。
• 在 Android 应用中执行后台任务（WorkManager）。
• 计划备份和报告。

在 Kotlin 中实现调度器的主要方法

让我们考虑三种最流行的方法：使用协程、经典的 Timer 和来自 Java 的 ScheduledExecutorService。每种方法都有其特点。

1. 基于 Kotlin 协程的调度器

协程是在 Kotlin 中处理异步的现代且高效的方式。要创建调度器，只需在协程内部使用 delay() 函数。这种方法轻量、不阻塞线程，非常适合简单任务。

import kotlinx.coroutines.*

fun main() = runBlocking {    println("调度器已启动。任务将在 3 秒后执行。")

    // 计划一个带延迟的任务    val job = launch {        delay(3000L) // 3 秒        println("任务已完成：时间到！")    }

    // 等待任务完成    job.join()    println("程序结束。") }

对于重复任务，在协程内部使用循环：

import kotlinx.coroutines.*

fun main() = runBlocking {    println("任务将每 2 秒执行一次，共 5 次。")

    val job = launch {        repeat(5) { iteration ->            delay(2000L)            println("执行 #${iteration + 1}: ${System.currentTimeMillis()}")        }    }

    job.join()    println("所有计划任务已完成。") }

2. 经典 Timer (Java/Kotlin)

java.util.Timer 是一种简单且许多开发人员熟悉的方法。它允许您计划带延迟和周期性的任务。但请记住，Timer 使用单个线程，如果任务执行时间较长，可能会延迟后续任务。

import java.util.*

fun main() {    val timer = Timer()

    // 计划一个延迟 2 秒的任务    timer.schedule(object : TimerTask() {        override fun run() {            println("任务在 2 秒后执行。")         }    }, 2000L)

    // 计划一个每 1.5 秒重复的任务，从 1 秒后开始    timer.schedule(object : TimerTask() {        override fun run() {            println("重复任务: ${System.currentTimeMillis()}")        }    }, 1000L, 1500L)

    // 给任务一些执行时间    Thread.sleep(5000L)    timer.cancel()    println("Timer 已停止。") }

3. ScheduledExecutorService（推荐用于多线程环境）

这个来自 Java java.util.concurrent 的类提供了更灵活的功能：线程池、异常处理和任务取消。在严肃的项目中，它比 Timer 更受欢迎。

import java.util.concurrent.*

fun main() {    val scheduler = Executors.newScheduledThre