更新 Home

chakcy 2025-09-14 04:24:40 +08:00
parent f6671650d6
commit f93c08210e

30
Home.md

@ -185,6 +185,36 @@ scheduler.update_listen_data("on_config_changed", "dark_mode=true")
# scheduler.stop_queue_scheduler()
```
## 核心概念
### MessageItem
任务消息的载体。重要字段:
- `id`: 唯一 ID自动生成
- `content`: 任务的主要内容dict
- `destination`: 必须与任务函数名一致。
- `priority`: 优先级(见 MessagePriority
- `status`: 状态(见 MessageStatus
- `expire_time`: 任务过期时间。
### 任务Task
一个被 `@TaskMounter.task` 装饰的普通 Python 函数。它接收一个 MessageItem 参数,执行业务逻辑,并返回一个可 JSON 序列化的结果。
### 监听器 (Listener)
一个被 `@ListenMounter.listener` 装饰的普通 Python 函数。它监听通过 `scheduler.update_listen_data(key, value)` 更新的数据,并在值发生变化时被触发。
### 调度器 (Scheduler)
系统的核心,包含四个部分:
1. **TaskScheduler**: 消费者,从队列取任务并执行。
2. **ReceiveScheduler**: 消费者,检查已完成的任务,执行用户回调。
3. **ListenDataScheduler**: 消费者,检查数据变化,触发监听器。
4. **CleanupScheduler**: 管理员,定期清理垃圾数据。
## 详细使用指南
### 消息优先级的使用