组合guava eventbus和AWT Event线程处理的最佳方法

Question

当你有一个异步事件总线和fire事件时,让我们说在UI中捕获的模型中你可能有以下问题:

已注册的处理程序在工作线程中执行,但所有UI swing更改都需要在AWT事件线程中执行.这意味着您需要将所有处理程序clode包含在内EventQueue.invokeLater(...).

这看起来像很多锅炉板代码.我想知道是否有更智能的解决方案来解决这个问题.

guava事件总线的扩展如何标记在特殊线程中执行的处理程序？这可以用注释标记,例如@ExecuteWithinEDT:

class EventBusChangeRecorder {
  @Subscribe @ExecuteWithinEDT void recordCustomerChange(ChangeEvent e) {
    recordChange(e.getChange());
  }
}

Answer 1

使用异步事件总线注册的处理程序在提供的任何Executor选择运行它们的线程上执行,而不一定是工作线程.

我所做的是创建了一个Executor在事件队列线程上运行东西的实现.这很简单:

public class EventQueueExecutor implements Executor {
  @Override public void execute(Runnable command) {
    EventQueue.invokeLater(command);
  }
}

然后你可以EventBus用它创建你的:

EventBus eventBus = new AsyncEventBus(new EventQueueExecutor());

然后所有处理程序将在事件队列线程上执行.

编辑:

转发事件的示例:

public class EventForwarder {
  private final EventBus uiEventBus;

  public EventForwarder(EventBus uiEventBus) {
    this.uiEventBus = uiEventBus;
  }

  // forward all events
  @Subscribe
  public void forwardEvent(Object event) {
    uiEventBus.post(event);
  }

  // or if you only want a specific type of event forwarded
  @Subscribe
  public void forwardEvent(UiEvent event) {
    uiEventBus.post(event);
  }
}

只需订阅您的主事件总线并将所有事件发布到主事件总线,但是将所有UI组件订阅到UI事件总线.

Answer 2

您可以创建仅在 AWT 线程上分派的 EventBus：

EventBus mybus = new AsyncEventBus("awt",
    new Executor() {
        public void execute (Runnable cmd) {
            if (EventQueue.isDispatchThread()) {
                cmd.run();
            } else {
                EventQueue.invokeLater(cmd);
            }
        }
    });