| 程序包 | 说明 |
|---|---|
| com.github.kfcfans.powerjob.worker.core.tracker.task |
| 限定符和类型 | 类和说明 |
|---|---|
class |
CommonTaskTracker
负责管理 JobInstance 的运行,主要包括任务的派发(MR可能存在大量的任务)和状态的更新
|
class |
FrequentTaskTracker
处理秒级任务(FIX_RATE/FIX_DELAY)的TaskTracker
FIX_RATE 直接由 ScheduledExecutorService 实现,精度高,推荐使用
FIX_DELAY 会有几秒的延迟,精度不是很理想
|
| 限定符和类型 | 方法和说明 |
|---|---|
static TaskTracker |
TaskTracker.create(ServerScheduleJobReq req)
静态方法创建 TaskTracker
|
static TaskTracker |
TaskTrackerPool.getTaskTrackerPool(Long instanceId)
获取 TaskTracker
|
static TaskTracker |
TaskTrackerPool.remove(Long instanceId) |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
TaskTrackerPool.atomicCreateTaskTracker(Long instanceId,
Function<Long,TaskTracker> creator) |
Copyright © 2020. All rights reserved.