多线程

src/main/java/com/aps/entity/Algorithm/Chromosome.java

@@ -12,6 +12,7 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.stream.Collectors;
 
 /**
@@ -113,7 +114,7 @@ public class Chromosome {
     /// <summary>
     /// 解码后的调度结果
     /// </summary>
-    private List<GAScheduleResult> ResultOld=new ArrayList<>();
+    private List<GAScheduleResult> ResultOld=new CopyOnWriteArrayList<>();
 
     /// <summary>
     /// 最早完工时间

src/main/java/com/aps/entity/basic/Machine.java

@@ -5,6 +5,7 @@ import lombok.Data;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.function.Consumer;
 
 @Data

src/main/java/com/aps/service/Algorithm/GeneticAlgorithm.java

@@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import java.time.LocalDateTime;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.stream.Collectors;
@@ -328,29 +329,16 @@ public class GeneticAlgorithm {
          FileHelper.writeLogFile("解码---------------"+population.size() );
 
         GeneticDecoder decoder = new GeneticDecoder(_GlobalParam, param.getBaseTime(), machines, orders, materials, machineScheduler,orderMaterials);
-        if(1==2) {
+
             CompletableFuture.allOf(population.stream()
                             .map(chromosome -> CompletableFuture.runAsync(() -> decode(decoder, chromosome, param, allOperations, globalOpList), decodeExecutor))
                             .toArray(CompletableFuture[]::new))
                     .join();
 
-        }
-
-        population.forEach(chromosome -> {
-            chromosome.setResult(new ArrayList<>());
-
-            // 假设Machine类有拷贝方法，或使用MapStruct等工具进行映射
-            chromosome.setMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
 
-            chromosome.setAllOperations(allOperations); // 简单拷贝，实际可能需要深拷贝
-            chromosome.setGlobalOpList(globalOpList); // 简单拷贝，实际可能需要深拷贝
-            //chromosome.setObjectiveWeights(_objectiveWeights);
-            chromosome.setBaseTime(param.getBaseTime());
-            //  chromosome.setInitMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
-            //   _sceneService.saveChromosomeToFile(chromosome, "12345679");
 
-        });
 
+        if(1==2) {
             if (population != null && population.size() > 0) {
                 population.parallelStream().forEach(chromosome -> {
                     decode(decoder, chromosome, param, allOperations, globalOpList);
@@ -358,22 +346,23 @@ public class GeneticAlgorithm {
 
 
             }
+        }
 
 
     }
 
     private  void  decode(GeneticDecoder decoder,Chromosome chromosome,ScheduleParams param, List<Entry> allOperations,List<GlobalOperationInfo> globalOpList) {
-//        chromosome.setResult(new ArrayList<>());
-//
-//        // 假设Machine类有拷贝方法，或使用MapStruct等工具进行映射
-//        chromosome.setMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
-//
-//        chromosome.setAllOperations(allOperations); // 简单拷贝，实际可能需要深拷贝
-//        chromosome.setGlobalOpList(globalOpList); // 简单拷贝，实际可能需要深拷贝
-//        //chromosome.setObjectiveWeights(_objectiveWeights);
-//        chromosome.setBaseTime(param.getBaseTime());
-//        //  chromosome.setInitMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
-//       //   _sceneService.saveChromosomeToFile(chromosome, "12345679");
+        chromosome.setResult(new CopyOnWriteArrayList<>());
+
+        // 假设Machine类有拷贝方法，或使用MapStruct等工具进行映射
+        chromosome.setMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
+
+        chromosome.setAllOperations(allOperations); // 简单拷贝，实际可能需要深拷贝
+        chromosome.setGlobalOpList(globalOpList); // 简单拷贝，实际可能需要深拷贝
+        //chromosome.setObjectiveWeights(_objectiveWeights);
+        chromosome.setBaseTime(param.getBaseTime());
+        //  chromosome.setInitMachines(ProductionDeepCopyUtil.deepCopyList(machines,Machine.class)); // 简单拷贝，实际可能需要深拷贝
+       //   _sceneService.saveChromosomeToFile(chromosome, "12345679");
 
         decoder.decodeChromosomeWithCache(chromosome);
         if (chromosome.getFitness() == 0) {

src/main/java/com/aps/service/Algorithm/MachineCalculator.java

@@ -65,7 +65,7 @@ public class MachineCalculator {
             Machine machine, int processingTime, LocalDateTime currentTime,
             String prevtime, List<GAScheduleResult> existingTasks,double oneTime,double quantity, boolean checkprevtime, boolean islockMachineTime
     ,boolean isInterrupt) {
-        List<GAScheduleResult> machineTasks =new ArrayList<>(existingTasks).stream()
+        List<GAScheduleResult> machineTasks =existingTasks.stream()
                 .filter(t -> t.getMachineId() == machine.getId())
                 .sorted(Comparator.comparingInt(GAScheduleResult::getStartTime))
                 .collect(Collectors.toList());