这是一个创建于 1383 天前的主题，其中的信息可能已经有所发展或是发生改变。
有一个 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