并发处理器
2020-09-28 10:02:08 0 举报
并发加载处理器
作者其他创作
大纲/内容
结束
否
任务是否已完成
任务是否存在
返回异常信息结果
执行任务run当前线程加载
是否大于最大等待限制
等待结果线程超过阀值,直接获取本地缓存
将本地缓存结果设置至任务结果。即可以唤醒还在等待超时时间内的线程快速获取到结果返回
获取正确结果/或者异常信息结果
是
是否该线程执行supplier
返回正确结果
获取任务等待线程数
获取任务结果
线程ABC对应任务Key相同
说明其他并发正在查询该结果
是否超时
并发加载器
任务加入MapputIfAbsent
移除任务
等待任务结果.get并设置超时时间
线程A、B、C
返回值是否为空
结果放入本地缓存
0 条评论
下一页
为你推荐
查看更多