Java, Entwurfsmuster: Mehrere Ereignisquellen und ein Event Handler

Question

Ich möchte ein Design in Java implementieren, wo ich mehrere Ereignisquellen (Threads) habe. Eine solche Ereignisquelle führt eine bestimmte Aufgabe aus und musste den eindeutigen Ereignishandler (Klasse) benachrichtigen, und dieser muss andere Aufgaben entsprechend den Ereignisquellenbenachrichtigungen ausführen.

Meine Frage ist: Wie implementiert man dieses Desiqn in geeigneter Weise in Java? Gibt es ein Entwurfsmuster, das diesem Entwurf ähnlich ist?

Vielen Dank im Voraus :).

Answer 1

Ich denke, Sie suchen nach dem Muster Observer. Java hat einige Standardschnittstellen (java.util.Observer, java.util.Observable), obwohl diese nicht typspezifisch sind; Sie könnten also Ihre eigenen betrachten, wenn die Domain dies zu erfordern scheint.

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

Klingt wie ein Schauspieler Muster für mich. Jeder Thread fungiert als Akteur, der eine einzelne Aufgabe erfüllt. Das Ergebnis wird in einer Warteschlange (Ja) festgelegt, die vom nächsten Akteur verarbeitet werden soll.

Ich habe jedoch keine Erfahrung mit Java-Actor-Frameworks. Wenden Sie sich an Google.

Answer 3

In GWT wird dies event bus genannt. Entweder GWT. HandlerManager oder GWTx. PropertyChangeSupport sind von Google empfohlene Implementierungen. Letzteres ist in J2SE seit 1.4.2 verfügbar.

Answer 4

Vielleicht verstehe ich Ihre Frage nicht, aber ich denke, dass Sie kein Designmuster benötigen, aber etwas aus dem java.util.concurrent Paket.

Ein ThreadPoolExecutor?

Answer 5

Observable Muster hat keine Meinung über Threading. In EventThread pattern kann der Listener angeben, in welchem ​​Thread und wann das Ereignis behandelt wird.

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