异步转同步方案
2023-11-23 15:53:06 0 举报异步转同步方案
作者其他创作
大纲/内容
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发起调度
解析回调结果
0 条评论
下一页
