Java, patrón de diseño: múltiples orígenes de eventos y un controlador de eventos

Question

Quiero implementar un diseño en Java donde tengo múltiples orígenes de eventos (subprocesos). Dicha fuente de eventos logra una tarea específica y tuvo que notificar al único Manejador de eventos (Clase) y este debe realizar otras tareas de acuerdo con las notificaciones de fuentes de eventos.

Mi pregunta es: ¿cómo implementar este diseño de la manera adecuada en Java? ¿Hay un patrón de diseño similar a este diseño?

Gracias de antemano :).

Answer 1

Creo que está buscando el patrón Observer. Java tiene algunas interfaces estándar (java.util.Observer, java.util.Observable), aunque estas no son específicas de tipo; por lo que podría considerar el suyo si el dominio parece requerirlo.

class MyThread implements Runnable { 
Observable observable; 

public MyThread(EventHandler observer) { 
    observable = new Observable(); 
    observable.addObserver(observer); 
} 

public void run() { 
    while (!done()) { 
    Object result = doStuff(); 
    observable.notifyObservers(result); 
    } 
} 
} 

// might have this be singleton 
class EventHandler implements Observer { 
public synchronized void update(Observable o, Object arg) { 
    accomplishOtherTask(); 
} 
} 

Answer 2

Suena como un patrón de actor para mí. Cada hilo actúa como un actor, logrando una sola tarea. La salida está configurada en una cola (sí) para ser procesada por el siguiente actor.

No tengo experiencia con frameworks java actor, sin embargo. Consulte Google para eso.

Answer 3

En GWT, esto se llama event bus. O bien GWT. HandlerManager o GWTx. PropertyChangeSupport son implementaciones recomendadas por Google. Este último está disponible en J2SE desde 1.4.2

Answer 4

Quizás no entiendo su pregunta, pero creo que no necesita ningún patrón de diseño, sino algo del paquete java.util.concurrent.

A ThreadPoolExecutor?

Answer 5

El patrón observable no tiene una opinión sobre el enhebrado. En EventThread pattern el oyente puede indicar en qué hilo y cuándo se maneja el evento.

public class MyObservableObject { 
    ... 
    void addListener(MyListener listener, Executor executor); 
} 
public interface MyListener { 
    void onEvent(Object sender, Object event); 
} 

// Example 
obj.addListener(myListener, CURRENT_THREAD); 
obj.addListener(myListener, myWorkQueue); 
obj.addListener(myListener, AWT_EDT); // or SWT_EDT 
obj.addListener(myListener, Executors.newSingleThreadScheduledExecutor());