Java 代碼實例解析設計模式之監(jiān)聽者模式
更新時間：2021年10月26日 14:15:12 作者：一月三千五
所謂監(jiān)聽者模式，我理解的是構建一個容器存放所有被監(jiān)聽的線程或對象，監(jiān)聽每個線程或對象發(fā)生的變化，若某個線程或對象觸發(fā)指定規(guī)則，那么則對所有被監(jiān)聽的線程或對象根據(jù)業(yè)務需要做處理
代碼展示
Main：測試類
ObServer：每個被監(jiān)聽的對象實現(xiàn)該接口，重寫該方法，完成自己的業(yè)務
public interface ObServer {
/**
* 當某一個被監(jiān)控的對象發(fā)生變化時
* 所有實現(xiàn)該方法處理方法
*/
void exceptionHandler();
}
Subject：監(jiān)聽者容器
public interface Subject {
/**
* 添加被觀察對象
*/
void add(ObServer obServer);
/**
* 通知所有被觀察者完成自己的 exceptionHandler 方法
*/
void notifyAllSubject();
}
SubjectHandler：監(jiān)聽者容器的實現(xiàn)類
public class SubjectHandler implements Subject {
/**
* 存放被監(jiān)聽對象
*/
private static final List<ObServer> SUBJECTS = Collections.synchronizedList(new LinkedList<>());
@Override
public void add(ObServer subject) {
SUBJECTS.add(subject);
}
@Override
public void notifyAllSubject() {
SUBJECTS.forEach(ObServer::exceptionHandler);
}
}
Thread1、Thread2 測試對象
模擬兩個線程對數(shù)據(jù)庫操作，若Threa1執(zhí)行時出異常了，那么終止所有線程并對其回滾。
Threa1:
public class Thread1 implements ObServer, Runnable {
@SneakyThrows
@Override
public void run() {
System.out.println("thread1 run");
Thread.sleep(1000);
System.out.println("t1 end");
}
@SneakyThrows
@Override
public void exceptionHandler() {
System.out.println("thread1 rollback.....");
}
}
Thread2:
public class Thread2 implements ObServer, Runnable {
private static Thread CURRENT_THREAD;
private static volatile boolean FLAG = false;
@SneakyThrows
@Override
public void run() {
CURRENT_THREAD = Thread.currentThread();
System.out.println("thread2 running");
int count = 0;
while (!FLAG) {
System.out.println(count);
count++;
}
System.out.println("thread2 end");
}
@SneakyThrows
@Override
public void exceptionHandler() {
FLAG = true;
CURRENT_THREAD.interrupt();
System.out.println("thread2 rollback.....");
}
}
測試Demo
public static void main(String[] args) throws InterruptedException {
// 創(chuàng)建監(jiān)聽容器
Subject subject = new SubjectHandler();
Thread1 thread1 = new Thread1();
Thread2 thread2 = new Thread2();
subject.add(thread1);
subject.add(thread2);
CompletableFuture.supplyAsync(() -> {
new Thread(thread1).start();
try {
Thread.sleep(10);
int a = 1 / 0; // 模擬線程1報錯
} catch (InterruptedException e) {
e.printStackTrace();
}
return true;
}).exceptionally((error) -> {
subject.notifyAllSubject();
return false;
});
CompletableFuture.supplyAsync(() -> {
new Thread(thread2).start();
return true;
}).exceptionally((error) -> {
subject.notifyAllSubject();
return false;
});
// main thread await
Thread.sleep(60 * 1000);
}
測試結果
在 java.util 包下提供了Observable（監(jiān)聽容器）和 Observer接口（被監(jiān)聽者），用法跟我們完全一致，只需實現(xiàn)Observer的update方法，把每個Observer子類添加到監(jiān)聽容器中。
注意：在調用監(jiān)聽容器的通知所有servers時首先調用一下其setChanged方法
將changed變?yōu)閠rue（默認flase）
到此這篇關于Java 代碼實例解析設計模式之監(jiān)聽者模式的文章就介紹到這了,更多相關Java 設計模式內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
詳解Java的Hibernate框架中的List映射表與Bag映射
這篇文章主要介紹了Java的Hibernate框架中的List映射表與Bag映射,Hibernate是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12
java Swing實現(xiàn)選項卡功能（JTabbedPane）實例代碼
這篇文章主要介紹了java Swing實現(xiàn)選項卡功能（JTabbedPane）實例代碼的相關資料,學習java 基礎的朋友可以參考下這個簡單示例，需要的朋友可以參考下2016-11-11
這篇文章主要給大家介紹了關于Spring Data分頁與排序的實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-12-12
SpringBoot結合ProGuard實現(xiàn)代碼混淆(最新版)
這篇文章主要介紹了SpringBoot結合ProGuard實現(xiàn)代碼混淆(最新版),文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-10-10
這篇文章主要介紹了Spring中緩存注解@Cache的使用詳解,使用注解對數(shù)據(jù)進行緩存功能的框架,只需要簡單地加一個注解，就能實現(xiàn)緩存功能，大大簡化我們在業(yè)務中操作緩存的代碼,需要的朋友可以參考下2023-07-07
這篇文章主要介紹了java表單提交中文亂碼的解決方法,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-10-10
這篇文章主要介紹了RocketMQ重試機制及消息冪代碼實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
本篇文章小編將為大家介紹，關于在java中 利用匿名內部類進行較簡潔的雙括弧初始化的方法，有需要的朋友可以參考一下2013-04-04
我們知道IOC（控制反轉）和AOP（面向切面編程）是spring的基石,除此之外spring的擴展能力非常強,下面這篇文章主要給大家介紹了關于Spring中11個最常用的擴展點的相關資料,需要的朋友可以參考下2022-12-12
java中僅有的創(chuàng)建對象的兩種方式：①.使用new操作符創(chuàng)建對象；②.使用clone方法復制對象。下面這篇文章主要通過JVM角度給大家詳細談談Java的clone操作的相關資料，文中通過示例代碼介紹的非常詳細，需要的朋友可以參考下2018-06-06