mejor manera de combinar EventBus guayaba y AWT manejo

Question

Cuando usted tiene un bus de eventos asíncronos hilo de eventos y eventos de fuego, digamos dentro del modelo que quedar atrapado en la interfaz de usuario que tiene probablemente el siguiente problema:

El domicilio el controlador se ejecuta en un hilo de trabajo, pero todos los cambios de desplazamiento de UI deben ejecutarse dentro del hilo de evento AWT. Esto significa que debe envolver todo su manipulador clode en EventQueue.invokeLater(...).

Parece un código de placa de caldera. Me pregunto si existe una solución más inteligente para ese problema.

¿Qué tal una extensión del bus de eventos guava que marca a un controlador para la ejecución dentro de un hilo especial? Esto se puede marcar con una anotación, p. @ExecuteWithinEDT:

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

Answer 1

Se puede crear un EventBus que despacha sólo en el hilo AWT:

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

Answer 2

Los controladores registrados con un bus de eventos asíncrono se ejecutan en cualquier hilo de las previstas Executor elige a ejecutarlos en , no necesariamente un hilo de trabajo.

Lo que he hecho es crear una implementación de Executor que ejecuta cosas en el hilo de la cola de eventos. Es muy sencillo:

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

continuación, puede simplemente crear su EventBus con eso:

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

A continuación, todos los manipuladores se ejecutarán en el hilo de cola de eventos.

Editar:

Un ejemplo de eventos de reenvío:

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); 
    } 
} 

Solo necesita suscribir que a su autobús evento principal y publicar todos los eventos al bus evento principal, pero se suscriben todos los componentes de interfaz de usuario a la UI evento de autobús.