JavaFX GUI冻结多任务场景下无法实时更新UI组件问题求助

问题根源 #

你遇到的GUI冻结、Platform.runLater提交的任务延迟到程序执行结束才运行的核心原因是：你在JavaFX应用线程上调用了阻塞方法Task.get()。
JavaFX所有界面更新、事件处理都依赖JavaFX应用线程，而get()是同步阻塞方法，调用后会直接卡住当前线程等待任务返回结果，这段时间JavaFX事件队列完全得不到调度，你提交的按钮更新任务自然不会执行，直到所有任务跑完、阻塞解除后才会批量执行堆积的界面更新任务，就出现了你说的按钮仅在程序结束后才变更的现象。

其他冗余/错误代码点 #

• setOnRunning回调本身就是在JavaFX应用线程上触发的，你额外套了一层Platform.runLater完全多余。
• 你同时调用了Service.start()和手动把Task提交到线程池执行，同一个任务被重复提交运行，属于逻辑错误。

修复方案 #

完全抛弃同步等待任务结果的写法，利用JavaFX Service自带的异步回调机制处理结果，不要在JavaFX应用线程上执行任何阻塞操作：

1. 移除setOnRunning中多余的Platform.runLater封装

task.setOnRunning(finishEvent -> {
    // 回调默认运行在JavaFX线程，直接修改界面即可
    btnStart.setText("läuft...");
});

2. 改造createTasks方法为异步逻辑，用计数器统计任务完成状态，在回调中汇总结果

// 新增成员变量统计任务完成数
private final AtomicInteger completedTaskCount = new AtomicInteger(0);
private int totalTaskCount;

// 方法返回值改为void，结果通过回调异步处理
public void createTasks(HashSet<String> pathsToAllFiles, ArrayList<String> searchParams, String searchType, boolean separatelyCreating) throws InterruptedException {
    ArrayList<HashMap<String, String>> listOfCompletelyProtocols = new ArrayList<>();
    ArrayList<HashMap<String, String>> listOfNotCompletelyProtocols = new ArrayList<>();
    ArrayList<HashMap<String, String>> listOfNoTestProtocols = new ArrayList<>();

    String[] allPaths = new String[pathsToAllFiles.size()];
    pathsToAllFiles.toArray(allPaths);
    HashSet<String[]> indexes = CustomTools.getStartEndIndexesByCores(allPaths);
    totalTaskCount = indexes.size();
    completedTaskCount.set(0);

    int processorsNum = Runtime.getRuntime().availableProcessors();
    ExecutorService exec = Executors.newWorkStealingPool(processorsNum);

    for (String[] indexPair : indexes) {
        int startIndex = Integer.parseInt(indexPair[0]);
        int endIndex = Integer.parseInt(indexPair[1]);

        CreateTabController.CustomService service = new CreateTabController.CustomService(startIndex, endIndex, allPaths, searchParams, searchType, separatelyCreating);
        service.setExecutor(exec);
        // 异步处理执行成功的结果
        service.setOnSucceeded(event -> {
            Map<String, ArrayList<HashMap<String, String>>> result = (Map<String, ArrayList<HashMap<String, String>>>) event.getSource().getValue();
            listOfNoTestProtocols.addAll(result.get("noTestingProtocols"));
            listOfCompletelyProtocols.addAll(result.get("completelyProtocols"));
            listOfNotCompletelyProtocols.addAll(result.get("notCompletelyProtocols"));
            int completed = completedTaskCount.incrementAndGet();
            // 所有任务执行完成后再做汇总处理
            if (completed == totalTaskCount) {
                exec.shutdown();
                Map<String,ArrayList<HashMap<String, String>>> allProcessedPDFs = new HashMap<>();
                allProcessedPDFs.put("noTestingProtocols", listOfNoTestProtocols);
                allProcessedPDFs.put("completelyProtocols", listOfCompletelyProtocols);
                allProcessedPDFs.put("notCompletelyProtocols", listOfNotCompletelyProtocols);
                // 此处调用你原来需要接收allProcessedPDFs的后续逻辑即可
                btnStart.setText("执行完成");
            }
        });
        // 异步处理执行失败的情况
        service.setOnFailed(event -> {
            service.getException().printStackTrace();
            int completed = completedTaskCount.incrementAndGet();
            if (completed == totalTaskCount) {
                exec.shutdown();
                btnStart.setText("执行异常");
            }
        });
        service.start();
    }
    // 不要同步等待结果，直接返回
}

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