在 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(): 计算待处理的异步任务数量。