Java, Mẫu thiết kế: Nhiều nguồn sự kiện và Một trình xử lý sự kiện

Question

Tôi muốn triển khai thiết kế trong Java, nơi tôi có nhiều nguồn sự kiện (Chủ đề). Nguồn sự kiện như vậy thực hiện một nhiệm vụ cụ thể và phải thông báo cho Trình xử lý sự kiện (Class) duy nhất và điều này phải thực hiện các tác vụ khác theo các thông báo nguồn sự kiện.

Câu hỏi của tôi là: cách triển khai desiqn này theo cách thích hợp trong Java? Có một mẫu thiết kế tương tự như thiết kế này?

Cảm ơn bạn trước :).

Answer 1

Tôi nghĩ bạn đang tìm kiếm mẫu Observer. Java không có một số giao diện chuẩn (java.util.Observer, java.util.Observable), mặc dù đây không phải là loại cụ thể; vì vậy bạn có thể xem xét của riêng bạn nếu miền dường như yêu cầu nó.

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

Âm thanh như mẫu hình diễn viên với tôi. Mỗi luồng đóng vai trò là một diễn viên, hoàn thành một nhiệm vụ duy nhất. Th eoutcome được đặt trên hàng đợi (yes) để được xử lý bởi diễn viên tiếp theo.

Tôi chưa có kinh nghiệm về khung công tác diễn viên java. Tham khảo ý kiến ​​của Google về điều đó.

Answer 3

Trong GWT, đây được gọi là event bus. Hoặc là GWT. HandlerManager hoặc GWTx. PropertyChangeSupport là các triển khai được Google đề xuất. Sau này có sẵn trong J2SE kể từ 1.4.2

Answer 4

Có lẽ tôi không hiểu câu hỏi của bạn, nhưng tôi nghĩ bạn không cần bất kỳ mẫu thiết kế nào, nhưng có gì đó từ gói java.util.concurrent.

Một ThreadPoolExecutor?

Answer 5

Mẫu quan sát không có ý kiến ​​về luồng. Trong EventThread pattern người nghe có thể nêu rõ chủ đề nào và khi nào sự kiện được xử lý.

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