CloudStack 的 AsyncJobManagerImpl
在 CloudStack 的 AsyncJobManagerImpl 类中,下列方法的作用如下:
-
getConfigComponentName(): 返回配置组件的名称。
-
getConfigKeys(): 返回与异步任务管理器相关的配置键列表。
-
getAsyncJob(): 根据异步任务的 ID 获取相应的异步任务对象。
-
findInstancePendingAsyncJobs(): 查找指定实例的待处理异步任务。
-
getPseudoJob(): 获取一个伪造的异步任务,用于处理异步任务的扩展。
-
submitAsyncJob(): 提交异步任务,将异步任务添加到异步任务队列中。
-
completeAsyncJob(): 完成异步任务,更新异步任务的状态和结果。
-
convertHumanReadableJson(): 将人类可读的 JSON 字符串转换为内部格式的 JSON 字符串。
-
updateAsyncJobStatus(): 更新异步任务的状态。
-
updateAsyncJobAttachment(): 更新异步任务的附件。
-
logJobJournal(): 记录异步任务的日志。
-
joinJob(): 加入一个异步任务。
-
disjoinJob(): 分离一个异步任务。
-
completeJoin(): 完成异步任务的联合。
-
syncAsyncJobExecution(): 同步执行异步任务的执行。
-
queryJob(): 查询异步任务的状态和结果。
-
obfuscatePassword(): 对密码进行模糊处理。
-
scheduleExecution(): 安排异步任务的执行。
-
getDispatcher(): 获取异步任务的调度器。
-
findWakeupDispatcher(): 查找等待唤醒的调度器。
-
getJobRunNumber(): 获取异步任务的执行次数。
-
getExecutorRunnable(): 获取执行异步任务的可运行对象。
-
getAndResetPendingSignals(): 获取和重置待处理信号。
-
executeQueueItem(): 执行队列项。
-
releaseSyncSource(): 释放同步源。
-
waitAndCheck(): 等待并检查。
-
marshallResultObject(): 序列化结果对象。
-
unmarshallResultObject(): 反序列化结果对象。
-
checkQueue(): 检查队列。
-
getHeartbeatTask(): 获取心跳任务。
-
getGCTask(): 获取垃圾回收任务。
-
expungeAsyncJob(): 清除异步任务。
-
getMsid(): 获取任务服务实例 ID。
-
wakeupByJoinedJobCompletion(): 根据联合任务的完成情况唤醒。
-
wakeupScan(): 唤醒扫描。
-
configure(): 配置异步任务管理器。
-
cleanupLeftOverJobs(): 清理未完成的异步任务。
-
onManagementNodeJoined(): 当管理节点加入时执行的操作。
-
onManagementNodeLeft(): 当管理节点离开时执行的操作。
-
onManagementNodeIsolated(): 当管理节点被隔离时执行的操作。
-
start(): 启动异步任务管理器。
-
stop(): 停止异步任务管理器。
-
publishOnEventBus(): 在事件总线上发布消息。
-
findFailureAsyncJobs(): 查找失败的异步任务。
-
countPendingJobs(): 计算待处理的异步任务数量。