modo migliore per combinare guava EventBus e AWT gestione degli eventi

Question

Quando si dispone di un bus evento asincrono filo, e gli eventi del fuoco, diciamo all'interno del modello che vengono catturato nell'interfaccia utente probabilmente avete il seguente problema:

La sede il gestore viene eseguito in un thread di lavoro, ma tutte le modifiche allo swing dell'interfaccia utente devono essere eseguite all'interno del thread di eventi AWT. Ciò significa che è necessario inserire tutti i clodi del gestore in EventQueue.invokeLater(...).

Questo assomiglia molto al codice della piastra della caldaia. Mi chiedo se esiste una soluzione più intelligente per questo problema.

Che dire di un'estensione del bus di eventi guava che contrassegna un gestore per l'esecuzione all'interno di un thread speciale? Questo potrebbe essere contrassegnato con un annotion, ad es. @ExecuteWithinEDT:

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

Answer 1

È possibile creare un EventBus che invia solo sul thread AWT:

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

Answer 2

I gestori registrati con un bus evento asincrono vengono eseguiti su qualunque discussione le previste Executor sceglie di eseguire loro su , non necessariamente un thread di lavoro.

Quello che ho fatto è stato creato un'implementazione di Executor che esegue roba sul thread della coda degli eventi. E 'piuttosto semplice:

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

È possibile quindi solo creare il EventBus con quella:

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

Poi saranno eseguiti tutti i gestori sul filo coda di evento.

Edit:

Un esempio di eventi di inoltro:

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

basta iscriversi che per il bus evento principale e post tutti gli eventi al bus evento principale, ma iscriversi tutti i componenti UI al Bus eventi UI.