代码优化
This commit is contained in:
@@ -16,6 +16,7 @@ import org.springframework.boot.ApplicationRunner;
|
|||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
import java.util.concurrent.*;
|
import java.util.concurrent.*;
|
||||||
@@ -55,14 +56,19 @@ public class AutoAccessTimer implements ApplicationRunner {
|
|||||||
// 创建一个ExecutorService来处理这些任务
|
// 创建一个ExecutorService来处理这些任务
|
||||||
List<Future<Void>> futures = new ArrayList<>();
|
List<Future<Void>> futures = new ArrayList<>();
|
||||||
// 提交任务给线程池执行
|
// 提交任务给线程池执行
|
||||||
for (int i = 0; i < 10; i++) {
|
// for (int i = 0; i < 10; i++) {
|
||||||
int index = i;
|
// int index = i;
|
||||||
|
// futures.add(executor.submit(() -> {
|
||||||
|
// accessDev(subLists.get(index));
|
||||||
|
// return null;
|
||||||
|
// }));
|
||||||
|
// }
|
||||||
|
for (List<CsEquipmentDeliveryPO> subList : subLists) {
|
||||||
futures.add(executor.submit(() -> {
|
futures.add(executor.submit(() -> {
|
||||||
accessDev(subLists.get(index));
|
accessDev(subList);
|
||||||
return null;
|
return null;
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
|
|
||||||
// 等待所有任务完成
|
// 等待所有任务完成
|
||||||
for (Future<Void> future : futures) {
|
for (Future<Void> future : futures) {
|
||||||
try {
|
try {
|
||||||
|
|||||||
Reference in New Issue
Block a user