Scala Akka中如何停止system.scheduler.schedule创建的定时调度任务

核心原因 #

你当前的问题根源是没有保存schedule方法返回的Cancellable实例，Akka调度器创建的定时任务和创建它的Actor生命周期默认没有绑定，所以停止创建任务的Actor不会自动取消已经提交的调度任务。

实现步骤 #

• 第一步：在管理调度任务的Actor内部维护一个存储Cancellable实例的集合，因为Akka Actor内部状态是线程安全的，直接使用可变集合即可：

import scala.collection.mutable
import akka.actor.Cancellable

// 放在管理调度的Actor类内部，作为私有成员变量
private val scheduledTasks = mutable.ArrayBuffer.empty[Cancellable]
// 如果需要单独取消指定任务，也可以用Map存储：
// private val scheduledTasks = mutable.HashMap.empty[String, Cancellable]

• 第二步：修改initialiseTask方法，把调度返回的Cancellable实例存入集合：

private def initialiseTask(taskName: String, taskActorRef: ActorRef, interval: FiniteDuration,
                             startDelay: FiniteDuration = 0 milliseconds, message: Any = "tick"): Unit = {
    logger.debug(s"Initialising task: $taskName")
    val cancellable = system.scheduler.schedule(startDelay,
      interval,
      taskActorRef,
      message)(system.dispatcher)
    scheduledTasks += cancellable
    // 如果用Map存储的话改为 scheduledTasks.put(taskName, cancellable)
    logger.debug(s"$taskName initialised")
  }

• 第三步：重写Actor的postStop生命周期方法，在Actor停止时批量取消所有调度任务：

override def postStop(): Unit = {
  super.postStop()
  logger.debug("Cancelling all scheduled tasks")
  scheduledTasks.foreach(_.cancel())
  scheduledTasks.clear()
}

注意事项 #

• Cancellable的cancel()方法是幂等的，多次调用不会抛出异常，无需额外判断是否已经取消
• 取消操作只会阻止未触发的调度任务执行，已经在运行中的任务不会被强制中断，符合常规调度器的设计逻辑
• 如果你的定时任务是和具体业务Actor绑定的，也可以把Cancellable存在对应业务Actor内部，在业务Actor的postStop方法里自行取消，无需统一在调度创建Actor里管理

内容的提问来源于stack exchange，提问作者TreyBCollier