
有一个 A 任务,可以分为 a1,a2……an 子任务,当子任务中遇到某种异常的时候重复执行 3 次,如果还是报异常就抛出,其他的错误直接抛出,如果子任务报错,A 任务整体回滚,返回报错信息。求教一下这种要求应该怎么写
1 hehezhang OP 求教 |
2 wolfie 2021 年 2 月 9 日 接口实时返回的,跟 async 没啥关系吧。 forkjoin 多任务并行、Guava retry 指定异常充视。 |
3 whispercero 2021 年 2 月 9 日 用消息实现不就可以了么 |
5 hehezhang OP @whispercero 能问一下具体应该怎么做吗 |
6 TeeMoCode 2021 年 2 月 9 日 能不能上点代码,看起来直观点 |
7 wangyanrui 2021 年 2 月 9 日 via iPhone 个人建议:自己开个线程池,手写任务,手动控制比较好 |
8 Vedar 2021 年 2 月 9 日 子任务执行完之后就等着主任务的状态通知(失败就重试 ) 如果主任务收集到所有子任务都完成了 就提交事务 否则就回滚 主任务就负责发起和监测子任务 就行了 |
9 leeg810312 2021 年 2 月 9 日 via Android 这不是 map reduce ? JAVA stream API 不就可以吗 |
10 br00k 2021 年 2 月 9 日 你这样的应该按同步处理,事物会滚。如果可以异步,担心失败可以用消息队列方式处理。 |
11 chocotan 2021 年 2 月 9 日 spring-retry |
12 Mystery0 2021 年 2 月 9 日 via Android 重试+分布式事务 |
13 kingfalse 2021 年 2 月 9 日 via Android 没太听明白你的具体意思,但是感觉你需要的是 CompletableFuture alloff 之类的 |