diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java index ccd213a..7010215 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/task/RyTask.java @@ -273,8 +273,6 @@ public class RyTask { List req = new ArrayList<>(); ExecutorService executorService = Executors.newFixedThreadPool(100); HttpClient client = HttpClient.newHttpClient(); - // 创建一个请求列表 - List> futures = new ArrayList<>(); for (Apply a : applies) { // 准备JSON负载 @@ -312,20 +310,12 @@ public class RyTask { // 发起异步请求,但不等待结果 CompletableFuture future2 = client.sendAsync(r.getRequest(), HttpResponse.BodyHandlers.ofString()) .thenApplyAsync(HttpResponse::body, executorService); - futures.add(future2); + future2.thenAccept(response -> { + log.info(response); + }); } - // 等待所有请求完成 - CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join(); - // 输出所有请求的响应(可选) - for (CompletableFuture future : futures) { - try { - System.out.println(future.get()); - } catch (Exception e) { - log.error(e.getMessage()); - } - } // 关闭线程池 executorService.shutdown();