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