Java并行HTTP请求：Swing GUI任务循环阻塞问题及优化咨询

一、任务列表无法清空的可能原因 #

• 任务未提交到线程池：你的代码仅创建了tasks列表，但没有将任务提交到ExecutorService执行。任务从未被执行，isDone()永远返回false，自然无法从列表中移除。
• isDone()方法实现异常：如果GetRequestTask自行实现了isDone()（而非依赖FutureTask的原生实现），可能存在逻辑错误，导致任务完成后未正确标记为done。
• getResponse()阻塞线程：若任务未完成时调用getResponse()会阻塞，一旦某个任务未完成，整个迭代循环会被卡住，无法处理其他任务，最终导致列表无法清空。
• 线程安全问题：ArrayList和responses都是非线程安全集合，多线程环境下修改可能导致迭代器状态不一致，比如任务已完成但迭代器无法读取到最新状态，或者出现ConcurrentModificationException（可能被隐藏导致循环异常）。
• 任务执行抛出未处理异常：如果GetRequestTask执行时抛出异常，FutureTask的isDone()会返回true，但调用get()（或getResponse()）会抛出ExecutionException。若未捕获该异常，代码会跳过移除任务的逻辑，导致任务滞留在列表中。

二、修复现有代码的建议 #

1. 确保任务提交到线程池
   先创建线程池并提交任务：

   ExecutorService executor = Executors.newFixedThreadPool(4); // 根据需求调整线程数
   ArrayList<Future<JSONObject>> tasks = new ArrayList<>(); // 用Future接收提交结果
   // 提交x个任务
   for (int i = 0; i < x; i++) {
       tasks.add(executor.submit(new GetRequestTask(...)));
   }
   

2. 替换为线程安全集合
   用CopyOnWriteArrayList存储任务，避免并发修改问题：

   CopyOnWriteArrayList<Future<JSONObject>> tasks = new CopyOnWriteArrayList<>();
   List<JSONObject> responses = Collections.synchronizedList(new ArrayList<>());
   

3. 安全获取任务结果
   先判断isDone()，再获取结果并处理异常：

   while (!tasks.isEmpty()) {
       for (Iterator<Future<JSONObject>> it = tasks.iterator(); it.hasNext();) {
           Future<JSONObject> task = it.next();
           if (task.isDone()) {
               try {
                   JSONObject response = task.get(); // Future的get()在isDone()后不会阻塞
                   responses.add(response);
                   it.remove();
               } catch (InterruptedException | ExecutionException e) {
                   // 处理任务执行异常，比如记录日志
                   e.printStackTrace();
                   it.remove(); // 即使出错也要移除任务
               }
           }
       }
       if (!tasks.isEmpty()) {
           Thread.sleep(100);
       }
   }
   executor.shutdown(); // 任务完成后关闭线程池
   

三、更简便高效的实现方式 #

针对Swing环境，推荐使用CompletableFuture（Java 8+）结合Swing事件调度线程（EDT）处理，无需手动轮询任务状态：

步骤1：执行初始请求并收集结果 #

// 创建x个初始请求的CompletableFuture
List<CompletableFuture<JSONObject>> initialFutures = new ArrayList<>();
ExecutorService executor = Executors.newFixedThreadPool(4);

for (int i = 0; i < x; i++) {
    CompletableFuture<JSONObject> future = CompletableFuture.supplyAsync(() -> {
        // 执行GetRequestTask的逻辑，返回JSONObject
        GetRequestTask task = new GetRequestTask(...);
        return task.call(); // Callable的call()方法
    }, executor);
    initialFutures.add(future);
}

// 等待所有初始请求完成，收集结果
CompletableFuture.allOf(initialFutures.toArray(new CompletableFuture[0]))
    .thenApply(v -> {
        List<JSONObject> initialResponses = new ArrayList<>();
        for (CompletableFuture<JSONObject> f : initialFutures) {
            try {
                initialResponses.add(f.get());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return initialResponses;
    })
    // 切换到EDT处理后续请求（因为后续可能需要更新UI）
    .thenAcceptAsync(initialResponses -> {
        // 步骤2：执行后续请求
        List<CompletableFuture<Void>> followupFutures = new ArrayList<>();
        for (JSONObject resp : initialResponses) {
            CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
                // 利用初始结果执行后续请求逻辑
                FollowupTask task = new FollowupTask(resp); // 假设后续任务用初始结果构造
                task.call();
            }, executor);
            followupFutures.add(future);
        }

        // 等待所有后续请求完成，更新UI
        CompletableFuture.allOf(followupFutures.toArray(new CompletableFuture[0]))
            .thenRunAsync(() -> {
                // 在EDT中更新GUI，比如提示任务完成
                JOptionPane.showMessageDialog(null, "所有任务执行完成");
            }, SwingUtilities::invokeLater);
    }, SwingUtilities::invokeLater);

// 程序退出时关闭线程池（可根据实际生命周期调整）
Runtime.getRuntime().addShutdownHook(new Thread(executor::shutdown));

为什么推荐这种方式？ #

• 无需手动轮询任务状态，通过回调机制处理任务完成事件，代码更简洁。
• 自动处理线程切换，thenAcceptAsync结合SwingUtilities::invokeLater确保UI操作在EDT执行，符合Swing线程安全规范。
• 更好的异常处理能力，可通过exceptionally()方法统一处理任务执行异常。

另外，如果你更倾向于使用SwingWorker，可以嵌套两个SwingWorker：第一个执行初始请求并收集结果，在done()方法中启动第二个SwingWorker执行后续请求，同样能避免阻塞GUI。

内容的提问来源于stack exchange，提问作者javaparallelizer