join

src/main/java/com/edgec/browserbackend/browser/task/BrowserTask.java

@@ -107,9 +107,10 @@ public class BrowserTask {
         long time = Instant.now().minusSeconds(300).toEpochMilli();
         List<IpResource> ipResources = ipResourceRepository.sampleTasks(6, time);
         log.error("buyIpTasks sample {} tasks", ipResources.size());
+        List<CompletableFuture> futureList = new ArrayList<>();
         for (IpResource ipResource : ipResources) {
             long start = System.currentTimeMillis();
-            CompletableFuture.runAsync(() -> {
+            CompletableFuture future = CompletableFuture.runAsync(() -> {
                 if (ipResourceRepository.lockTask(ipResource)) {
                     try {
                         boolean result = false;
@@ -182,7 +183,9 @@ public class BrowserTask {
                     }
                 }
             }, ThreadPoolUtils.buyIpTasksPool);
+            futureList.add(future);
         }
+        CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).join();
     }
 
     @Scheduled(cron = "0 0/1 * * * ?")