java - 如何锁定 Java 线程，以便在 Platform.runLater 完成之前锁定其他线程

Question

在我的基于 OSGi 的应用程序包中，可以随时启动和停止。面向 UI 的 bundle 向“桌面” bundle 注册一个 javafx 节点。操作 UI 必须使用 Platform.runLater() 在 JavaFX UI 线程上完成，这将安排它稍后执行。

我想确保一次只有一个调用者可以修改桌面。我使用锁和条件来实现此目的。

public class DesktopContent implements ContentManager {
  private final Pane desktop;
  private final AtomicReference<Node> weather = new AtomicReference<>();
  private final ReentrantLock lock = new ReentrantLock();

  @Override
  public void setWeatherWidget(Node node) {
    updateFX(() -> replaceNode(desktop.getChildren(), weather, node));
  }

  private void updateFX(Runnable runnable) {
    lock.lock();
    Condition condition = lock.newCondition();
    try {
        if (Platform.isFxApplicationThread()) {
            runnable.run();
        } else {
            updateFX(runnable, condition);
            condition.await();
        } 
    } catch (InterruptedException e) {
        logger.log(Level.WARNING, "While waiting for 'updating' condition", e);
    } finally {
        lock.unlock();
    }
  }

  private void updateFX(Runnable runnable, Condition condition) {
    Platform.runLater(() -> {
        lock.lock();
        try {
            runnable.run();
        } finally {
            condition.signal();
            lock.unlock();
        }
    });
}

private void replaceNode(List<Node> children, AtomicReference<Node> current, Node newNode) {
    SequentialTransition st = new SequentialTransition();
    ObservableList<Animation> transformations = st.getChildren();
    Node oldNode = current.getAndSet(newNode);

    if (oldNode != null) {
        FadeTransition ft = new FadeTransition(Duration.millis(350), oldNode);
        ft.setToValue(0d);
        ft.setOnFinished(e -> children.remove(oldNode));
        transformations.add(ft);
    }

    if (newNode != null) {
        newNode.setLayoutX(100d);
        newNode.setLayoutY(100d);
        FadeTransition ft = new FadeTransition(Duration.millis(350), newNode);
        ft.setFromValue(0d);
        ft.setToValue(1d);
        children.add(newNode);
        transformations.add(ft);
    }

    st.play();

}

}

我不确定这是否正确。如果调用者不在应用程序线程上，框架将调度可运行对象的执行，调用者将等待，直到满足条件。

但如果与此同时其他人调用 setWeatherWidget，我想它会很高兴地被授予锁定，并调度另一个 runLater。这意味着我也可以完全跳过任何锁定。

应该如何使用锁正确处理这个问题？引入另一个“全局”锁？或者这是过度设计并且所有这些锁定业务都是不必要的？

Answer 1

我认为您可以做到这一点，而无需深入了解锁、条件等较低级别的细节。本质上，您希望对 setWeatherWidget 单线程进行所有调用(一次只能调用一个) )，同时确保必须在 FX 应用程序线程上执行的代码已完成。关键是 FX 应用程序线程已经是单个线程:因此您可以通过向 FX 应用程序线程发送请求并阻塞直到这些请求完成来实现此目的:

public class DesktopContent implements ContentManager {
    private final Pane desktop;
    private final AtomicReference<Node> weather = new AtomicReference<>();

    @Override
    public void setWeatherWidget(Node node) {
        updateFX(() -> replaceNode(desktop.getChildren(), weather, node));
    }

    private void updateFX(Runnable runnable) {
        try {
            if (Platform.isFxApplicationThread()) {
                runnable.run();
            } else {
                FutureTask<Void> task = new FutureTask<>(runnable, null);
                Platform.runLater(task);
                // block until task completes:
                task.get();
            } 
        } catch (InterruptedException e) {
            logger.log(Level.WARNING, "While waiting for 'updating' condition", e);
        }
    }

    private void replaceNode(List<Node> children, AtomicReference<Node> current, Node newNode) {
        SequentialTransition st = new SequentialTransition();
        ObservableList<Animation> transformations = st.getChildren();
        Node oldNode = current.getAndSet(newNode);

        if (oldNode != null) {
            FadeTransition ft = new FadeTransition(Duration.millis(350), oldNode);
            ft.setToValue(0d);
            ft.setOnFinished(e -> children.remove(oldNode));
            transformations.add(ft);
        }

        if (newNode != null) {
            newNode.setLayoutX(100d);
            newNode.setLayoutY(100d);
            FadeTransition ft = new FadeTransition(Duration.millis(350), newNode);
            ft.setFromValue(0d);
            ft.setToValue(1d);
            children.add(newNode);
            transformations.add(ft);
        }

        st.play();

    }

}