lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(web): 修复异步并发没有生效

Browse Source
This commit is contained in:
兰缘小妖
2023-06-13 15:30:49 +08:00
parent 36a72f7327
commit 4062c87785
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/OverviewController.java
View File

@@ -61,7 +61,7 @@ public class OverviewController extends BaseController {
tableFocusCountFuture, tableFocusCountFuture,
hudiCountFuture, hudiCountFuture,
hudiFocusCountFuture hudiFocusCountFuture
); ).get();
return responseData() return responseData()
.withData("table_count", tableCountFuture.get()) .withData("table_count", tableCountFuture.get())
.withData("table_focus_count", tableFocusCountFuture.get()) .withData("table_focus_count", tableFocusCountFuture.get())
@@ -130,7 +130,7 @@ public class OverviewController extends BaseController {
CompletableFuture<Long> unReceiveFocusCount = CompletableFuture.supplyAsync(() -> infoService.unReceiveVersionFocusTableCount(version), ExecutorProvider.EXECUTORS); CompletableFuture<Long> unReceiveFocusCount = CompletableFuture.supplyAsync(() -> infoService.unReceiveVersionFocusTableCount(version), ExecutorProvider.EXECUTORS);
CompletableFuture<Long> unScheduledNormalTableCount = CompletableFuture.supplyAsync(() -> infoService.unScheduledNormalTableCount(version), ExecutorProvider.EXECUTORS); CompletableFuture<Long> unScheduledNormalTableCount = CompletableFuture.supplyAsync(() -> infoService.unScheduledNormalTableCount(version), ExecutorProvider.EXECUTORS);
CompletableFuture<Long> unScheduledFocusTableCount = CompletableFuture.supplyAsync(() -> infoService.unScheduledFocusTableCount(version), ExecutorProvider.EXECUTORS); CompletableFuture<Long> unScheduledFocusTableCount = CompletableFuture.supplyAsync(() -> infoService.unScheduledFocusTableCount(version), ExecutorProvider.EXECUTORS);
CompletableFuture.allOf(unReceiveNormalTableCount, unReceiveFocusCount, unScheduledNormalTableCount, unScheduledFocusTableCount); CompletableFuture.allOf(unReceiveNormalTableCount, unReceiveFocusCount, unScheduledNormalTableCount, unScheduledFocusTableCount).get();
return responseData() return responseData()
.withData("version", version) .withData("version", version)
.withData("unReceive", Maps.immutable.of("normal", unReceiveNormalTableCount.get(), "focus", unReceiveFocusCount.get())) .withData("unReceive", Maps.immutable.of("normal", unReceiveNormalTableCount.get(), "focus", unReceiveFocusCount.get()))