停止主线程，直到JavaFX事件队列上的所有事件都已执行

Question

在调试应用程序时，我希望主线程在我放入JavaFX事件队列的每个Runnable之后等待

Platform.runLater(new Runnable()... )

等待它被执行(即可见)。然而，这里有两个问题:

首先，它并不是一个标准的、GUI驱动的JavaFX应用程序。它更像是一个脚本，显示和更新一个JavaFX阶段。所以结构看起来像这样：

public static void main(String [] args){
    //do some calculations
    SomeView someView = new SomeView(data); //SomeView is basically a wrapper for  a stage
    PlotUtils.plotView(someView) //displays SomeView (i.e. the stage)
    //do some more calculations
    someView.updateView(updatedData)
    //do some more calculations
}

public class SomeView {
    private static boolean viewUpdated = false;
    private ObservableList<....> observableData;
    public void updateView(Data data){
        Platform.runLater(new Runnable() {
            @Override
            public void run() {
                observableData.addAll(data);
                boolean viewUpdated = true; 
            }
        });
    //If configured (e.g using boolean switch), wait here until
    //the Runnable has been executed and the Stage has been updated.
    //At the moment I am doing this by waiting until viewUpdated has been
    //set to true ... but I am looking for a better solution!
    }
}

其次，禁用此“功能”应该很容易，即等待Runnable执行（使用当前方法没有问题，但使用替代方法也应该可行）。

做这件事的最好方法是什么？

例如。是否有类似阻塞版本的东西来在JavaFX线程上执行Runnable，或者是否有一种简单的方法来检查事件队列上的所有事件是否都已执行/事件队列是否为空......？

Answer 1

这是基于JavaFX2的一般思想:我可以暂停一个后台任务/服务吗？

基本思想是提交未来任务

// on some background thread:

Runnable runnable = () -> { /* code to execute on FX Application Thread */};
FutureTask<Void> task = new FutureTask<>(runnable, null);
Platform.runLater(task);
task.get();

不得在FX应用程序线程上执行此代码块，因为这将导致死锁。

如果您想使其易于配置，可以执行以下操作：

// Wraps an executor and pauses the current thread 
// until the execution of the runnable provided to execute() is complete

// Caution! Calling the execute() method on this executor from the same thread
// used by the underlying executor will result in deadlock.

public class DebugExecutor implements Executor {
    private final Executor exec ;

    public DebugExecutor(Executor executor) {
        this.exec = executor ;
    }

    @Override
    public void execute(Runnable command) {
        FutureTask<Void> task = new FutureTask<>(command, null);
        exec.execute(command);
        try {
            task.get();
        } catch (InterruptedException interrupt) {
            throw new Error("Unexpected interruption");
        } catch (ExecutionException exc) {
            throw new RuntimeException(exc);
        }
    }
}

现在在您的应用程序中，您可以执行：

// for debug:
Executor frontExec = new DebugExecutor(Platform::runLater);
// for production:
// Executor frontExec = Platform::runLater ;

并将对 Platform.runLater（...） 的所有调用替换为 frontExec.execute（...）;

根据所需的可配置性，您可以基于命令行参数或属性文件（或者，如果您使用的是依赖关系注入框架，则可以注入它）有条件地创建 frontExec）。

Answer 2

还有< code > platform impl . runandwait()使用倒计时闩锁，只要您不从JavaFX线程调用它