使用Guava EventBus实现Java多线程

Question

我正在使用番石榴事件总线。我有一个类似服务器的对象，它应该一直在运行，监听要发布给b用户的事件。所以在junit测试中（MyObject是被测试类），我在它自己的线程中创建它来模拟这一点并防止阻塞：

  @Test    
  public void test() {
      EventBus eventBus = new EventBus();

      Thread thread= new Thread() {
         @Override
         public void run()
         {
            logger.debug("Creating new thread");
            MyObject myObject = new MyObject(eventBus);
         }
      };

      thread.start();
      ...
  }

一切都很好，myObject是在它自己的线程Thread1中创建的。然后，我在测试中向事件总线发布一个事件：

eventBus.post(triggerObject);

奇怪的是，我发现MyObject类中的订阅方法的所有操作/日志记录都再次在主线程中执行。myObject会等待某些其他部分的响应，这会阻止我的测试，因为它位于主线程中。为什么会出现这种情况？是不是我在EventBus或Java线程上做错了什么？

Answer 1

在创建的线程中，除了创建一个最终在堆（线程之间共享）中结束的对象之外，您什么也不做，但是由于对它的引用在运行后不被维护，所以它也丢失了。

在调用EventBus.Post（事件）；的同一线程中调用MyObject中的@subscribe方法，而不是在创建MyObject的线程中。

奇怪的是，我发现MyObject类中的订阅方法的所有操作/日志记录都再次在主线程中执行

如果您的MyObject类有一个@subscribe方法，那么它为什么需要构造函数内部的EventBus实例呢？你可能想

MyObject myObject = new MyObject();
eventBus.register(myObject);`

而不是myObject myObject=new myObject（eventBus）；