# [058][调度模块]任务生命周期事件与监听器机制

本文章代码: [gitee](https://gitee.com/yunjiao-source/tutorials4j) , [gitcode](https://gitcode.com/yun-jiao/tutorials4j) , [github](https://github.com/yunjiao-source/tutorials4j)


## 摘要
为了便于监控、审计或联动其他系统，框架定义了 `ChangeStatusEvent` 事件和 `ChangeStatusEventConsumer` 接口，使外部可以订阅任务状态变化。本文分析事件产生、消费流程及扩展方式。

## 1. 事件定义
```java
@Builder
public record ChangeStatusEvent(
    Instant timestamp,
    String taskName,
    TaskStatusEnum taskStatus,
    TaskCondition lastTaskCondition,
    String message,
    Throwable throwable
) {}
```
状态包括：`CREATED`、`STARTED`、`COMPLETED`、`STOPPED`、`CANCELLED`、`EXCEPTION`。

## 2. 事件触发点
在 `ScheduleTaskManager` 中，每个关键操作都会调用 `notifyListeners()`：
```java
private void startEvent(String taskName) {
    notifyListeners(taskName, TaskStatusEnum.STARTED, null, null);
}
private void stopEvent(String taskName, String message) {
    doCancelTask(taskName);
    notifyListeners(taskName, TaskStatusEnum.STOPPED, message, null);
}
// 类似地，completeEvent, failureEvent, cancelEvent...
```

## 3. 消费者注册
`ScheduleTaskManager` 构造函数接收 `ObjectProvider<ChangeStatusEventConsumer>`，将所有实现了该接口的 Bean 收集起来：
```java
public ScheduleTaskManager(TaskRepository<?> taskRepository,
                           List<ChangeStatusEventConsumer> consumers) {
    this.taskRepository = taskRepository;
    this.consumers = consumers;
}
```
消费者可以是任何 Spring Bean，例如：
```java
@Component
@Slf4j
public class LoggingEventConsumer implements ChangeStatusEventConsumer {
    @Override
    public void consumer(ChangeStatusEvent event) {
        log.info("任务 {} 状态变为 {}", event.taskName(), event.taskStatus());
    }
}
```

## 4. 扩展点
- 持久化事件到数据库，用于历史追踪。
- 通过消息队列将事件转发到其他微服务。
- 结合监控系统（如 Prometheus）实时上报任务执行情况。

## 5. 设计优势
- **解耦**：任务调度核心不关心事件被如何使用，只需广播。
- **多监听器**：支持任意数量的消费者，且异常隔离（单个消费者异常不影响其他消费者）。



为了便于监控、审计或联动其他系统，框架定义了 ChangeStatusEvent 事件和 ChangeStatusEventConsumer 接口，使外部可以订阅任务状态变化。本文分析事件产生、消费流程及扩展方式。

[058][调度模块]任务生命周期事件与监听器机制

编程语言

后端

开发工具

框架通过ChangeStatusEvent事件与ChangeStatusEventConsumer接口实现任务状态变更的订阅与广播，覆盖创建、启动、完成、停止、取消及异常六种状态。ScheduleTaskManager在关键操作触发通知，支持多消费者注册与异常隔离，便于日志记录、持久化、消息转发及监控系统集成，实现调度核心与外部系统的解耦。

消息队列

代码解释

数据库

2026上云采购 | AI焕新·智启新局

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

框架通过ChangeStatusEvent事件与ChangeStatusEventConsumer接口实现任务状态变更的订阅与广播，覆盖创建、启动、完成、停止、取消及异常六种状态。ScheduleTaskManager在关键操作触发通知，支持多消费者注册与异常隔离，便于日志记录、持久化、消息转发及监控系统集成，实现调度...

[058][调度模块]任务生命周期事件与监听器机制-腾讯云开发者社区-腾讯云

[058][调度模块]任务生命周期事件与监听器机制

[058][调度模块]任务生命周期事件与监听器机制

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐