| | |
|---|
| | | CompletableFuture<List<Map<String,Object>>> tbAttResWaterBlock = getTbInfo("tb_att_res_water_block",resGuid,executor); |
|---|
| | | CompletableFuture<List<Map<String,Object>>> tbAttResWaterDelivery = getTbInfo("tb_att_res_water_delivery",resGuid,executor); |
|---|
| | | CompletableFuture<List<Map<String,Object>>> tbFileStorageLocation = getTbInfo("tb_file_storage_location",resGuid,executor); |
|---|
| | | CompletableFuture<List<Map<String,Object>>> tbResStagCapDisc = getTbInfo("tb_res_stag_cap_disc",resGuid,executor); |
|---|
| | | //等待所有任务执行完成 |
|---|
| | | try { |
|---|
| | | CompletableFuture.allOf( |
|---|
| | |
|---|
| | | tbAttResSafetyMonitor, |
|---|
| | | tbAttResStagChar, |
|---|
| | | tbAttResWaterBlock, |
|---|
| | | tbAttResWaterDelivery, |
|---|
| | | tbResStagCapDisc |
|---|
| | | tbAttResWaterDelivery |
|---|
| | | ).get(); |
|---|
| | | // 数据处理 |
|---|
| | | list.addAll(tbAttResBaseInfo.get()); |
|---|
| | |
|---|
| | | list.addAll(tbAttResWaterBlock.get()); |
|---|
| | | list.addAll(tbAttResWaterDelivery.get()); |
|---|
| | | list.addAll(tbFileStorageLocation.get()); |
|---|
| | | list.addAll(tbResStagCapDisc.get()); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } catch (ExecutionException e) { |
|---|
