wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3828: fix error handling

Browse Source
This commit is contained in:
yanglin 2024-12-26 09:33:42 +08:00
parent da96e90056
commit 93323fb4e0
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
inside-notices/src/main/java/cn/axzo/msg/center/utils/BatchController.java
View File

@ -34,14 +34,7 @@ public class BatchController {
}
public void submit(Runnable task) {
submitCount++;
if (submitCount <= parallelismThreshold) {
info("using sync");
task.run();
return;
}
info(String.format("using async because of parallelismThreshold > %d", parallelismThreshold));
asyncTasks.runAsync(() -> {
Runnable runner = () -> {
Exception exception = error.get();
if (exception != null) {
warn("operation aborted because of other batch's error", exception);
@ -53,7 +46,15 @@ public class BatchController {
warn("operation failed", e);
error.compareAndSet(null, e);
}
});
};
submitCount++;
if (submitCount <= parallelismThreshold) {
info("using sync");
runner.run();
return;
}
info(String.format("using async because of parallelismThreshold > %d", parallelismThreshold));
asyncTasks.runAsync(runner);
}
public void awaitTermination(long timeout, TimeUnit unit) throws Exception {