0

我有一个 JavaFX 8 应用程序。它使用一种观察者模式来对事件做出反应：

public class EventBus {

    public static final EventBus INSTANCE = new EventBus();

    private final Set<EventListener> listeners;

    private EventBus() {
        listeners = new HashSet<>();
    }

    public void register(EventListener listener) {
        listeners.add(listener);
    }

    public void fire(Event event) {
        listeners.forEach(listener -> listener.eventFired(event));
    }
}

到目前为止，它对我的​​所有用例都运行良好：

  • 与按钮的交互
  • Platform.runLater()来自外部控制器的事件，我通过启动线程观察
  • 等等

现在我想启动嵌入式 Undertow HTTP 服务器并在其中部署一个 JAX-RS 端点。每当有请求进入时，我想使用上述事件总线从该端点内触发一个事件。所以，这就是我启动 Undertow 并部署我的 JAX-RS 应用程序的方式：

UndertowJaxrsServer server = new UndertowJaxrsServer().start();
server.deploy(new MyEndpoint(eventBus));

事情是new UndertowJaxrsServer().start()异步调用，它自己启动一个线程。然后当MyEndpoint处理一个请求并尝试触发一个事件时，它发生在由 Undertow 启动的那个线程中。

所以在事件监听器中，如果我尝试对 UI 进行任何更新，我会得到：

java.lang.IllegalStateException: Not on FX application thread; currentThread = XNIO-1 task-1
    at com.sun.javafx.tk.Toolkit.checkFxUserThread(Toolkit.java:236)
    at com.sun.javafx.tk.quantum.QuantumToolkit.checkFxUserThread(QuantumToolkit.java:423)
    at javafx.scene.Parent$2.onProposedChange(Parent.java:367)
    at com.sun.javafx.collections.VetoableListDecorator.clear(VetoableListDecorator.java:294)
    at ui.DialogManager.showDialog(DialogManager.java:109)

最后，我的问题是有没有办法明确告诉 JavaFX 在 UI 线程中运行一段代码，即使调用堆栈来自另一个（我无法控制并且我不能这样做Platform.runLater()） .

谢谢！

4

1 回答 1

3

如果是您的类，则使用或更改类MyEndpoint围绕方法调用：fire(Event event)Platform.runLater()EventBus

public class EventBus {

    public static final EventBus INSTANCE = new EventBus();

    private final Set<EventListener> listeners;

    private EventBus() {
        listeners = new HashSet<>();
    }

    public void register(EventListener listener) {
        listeners.add(listener);
    }

    public void fire(Event event) {
        Platform.runLater(() -> {
            listeners.forEach(listener -> listener.eventFired(event));    
        });
    }
}
于 2017-10-12T12:37:12.763 回答