Guava EventBus调度

Question

我正在使用Guava的EventBus启动一些处理并报告结果。下面是一个非常简单的可编译示例：

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;

public class Test {

    public static class InitiateProcessing { }
    public static class ProcessingStarted { }
    public static class ProcessingResults { }
    public static class ProcessingFinished { }

    public static EventBus bus = new EventBus();

    @Subscribe
    public void receiveStartRequest(InitiateProcessing evt) {
        System.out.println("Got processing request - starting processing");
        bus.post(new ProcessingStarted());

        System.out.println("Generating results");
        bus.post(new ProcessingResults());
        System.out.println("Generating more results");
        bus.post(new ProcessingResults());

        bus.post(new ProcessingFinished());
    }

    @Subscribe
    public void processingStarted(ProcessingStarted evt) {
        System.out.println("Processing has started");
    }

    @Subscribe
    public void resultsReceived(ProcessingResults evt) {
        System.out.println("got results");
    }

    @Subscribe
    public void processingComplete(ProcessingFinished evt) {
        System.out.println("Processing has completed");
    }


    public static void main(String[] args) {
        Test t = new Test();
        bus.register(t);
        bus.post(new InitiateProcessing());
    }
}

Got processing request - starting processing
Processing has started
Generating results
got results
Generating more results
got results
Processing has completed

Got processing request - starting processing
Generating results
Generating more results
Processing has started
got results
got results
Processing has completed

  /**
   * Drain the queue of events to be dispatched. As the queue is being drained,
   * new events may be posted to the end of the queue.
   */
  void dispatchQueuedEvents() {
    // don't dispatch if we're already dispatching, that would allow reentrancy
    // and out-of-order events. Instead, leave the events to be dispatched
    // after the in-progress dispatch is complete.
    if (isDispatching.get()) {
        return;
    }
    // dispatch event (omitted)

发生的情况是，由于我已经分派了顶级initiateprocessing事件，其余的事件只是被推送到队列的末尾。我希望它的行为与.NET事件类似，在该事件中，调用事件直到所有处理程序完成后才返回。

我不太明白这样实现的原因。当然，可以保证事件是有序的，但是周围代码的顺序会被完全扭曲。

有没有什么方法可以让总线按照描述的方式运行并产生所需的输出？我在Javadocs中读到

这里出现问题的原因是我在订阅者内部posting。由于事件总线是不可重入的，所以这些“子帖子”会排队，并在第一个处理程序完成后进行处理。我可以注释掉EventBus源代码中的if(isDispatching.get（））{return；}部分，并且所有的行为都与我预期的一样--所以真正的问题是我这样做引入了哪些潜在的问题？看来设计师们做出了不允许重入的认真决定。

Answer 1

EventBus通常基于这样一个原则进行操作：将事件发布到总线的代码不应该关心订阅者对事件做了什么或什么时候做了什么，除了遵守事件发布的顺序（在同步事件总线的情况下）。

如果您希望在方法过程中的特定时间调用特定方法，并且希望在方法继续之前确保这些方法完成（就像您在示例中所做的那样），为什么不直接调用这些方法呢？当您使用事件总线时，您将显式地将您的代码与响应给定事件所发生的事情分离开来。这在许多情况下是可取的，也是eventbus存在的主要原因，但在这里似乎并不完全是您想要的。