ConcurrentHashMap.putspan style=\"font-size: inherit;\
是否有obj超时
NotifyBody.notify()
删除缓存
异步任务侧
回调组件
业务逻辑
NotifyBody.wait()
解析消息taskId:status
订阅者线程
waitCallBack(taskId)
生成taskId传给异步任务
等待消息
订阅消息
调度结束
new NotifyBody()设置当前时间
设置objstatus=false;errorMsg=\"回调超时\"
ConcurrentHashMap.get(taskId)
定时查询ConcurrentHashMap
业务侧
监控线程
否
push消息
PowerJob发起调度
解析回调结果
