快捷導(dǎo)航

Java 代碼實(shí)例解析設(shè)計(jì)模式之監(jiān)聽者模式

更新時(shí)間：2021年10月26日 14:15:12 作者：一月三千五

所謂監(jiān)聽者模式，我理解的是構(gòu)建一個(gè)容器存放所有被監(jiān)聽的線程或?qū)ο?，監(jiān)聽每個(gè)線程或?qū)ο蟀l(fā)生的變化，若某個(gè)線程或?qū)ο笥|發(fā)指定規(guī)則，那么則對(duì)所有被監(jiān)聽的線程或?qū)ο蟾鶕?jù)業(yè)務(wù)需要做處理

代碼展示

Main：測(cè)試類

ObServer：每個(gè)被監(jiān)聽的對(duì)象實(shí)現(xiàn)該接口，重寫該方法，完成自己的業(yè)務(wù)

public interface ObServer {
 
    /**
     * 當(dāng)某一個(gè)被監(jiān)控的對(duì)象發(fā)生變化時(shí)
     * 所有實(shí)現(xiàn)該方法處理方法
     */
    void exceptionHandler();
 
}

Subject：監(jiān)聽者容器

public interface Subject {
 
 
    /**
     * 添加被觀察對(duì)象
     */
    void add(ObServer obServer);
 
    /**
     * 通知所有被觀察者完成自己的 exceptionHandler 方法
     */
    void notifyAllSubject();
 
}

SubjectHandler：監(jiān)聽者容器的實(shí)現(xiàn)類

public class SubjectHandler implements Subject {
 
    /**
     * 存放被監(jiān)聽對(duì)象
     */
    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 測(cè)試對(duì)象

模擬兩個(gè)線程對(duì)數(shù)據(jù)庫(kù)操作，若Threa1執(zhí)行時(shí)出異常了，那么終止所有線程并對(duì)其回滾。

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

測(cè)試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報(bào)錯(cuò)
            } 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);
    }

測(cè)試結(jié)果

在 java.util 包下提供了Observable（監(jiān)聽容器）和 Observer接口（被監(jiān)聽者），用法跟我們完全一致，只需實(shí)現(xiàn)Observer的update方法，把每個(gè)Observer子類添加到監(jiān)聽容器中。

注意：在調(diào)用監(jiān)聽容器的通知所有servers時(shí)首先調(diào)用一下其setChanged方法

將changed變?yōu)閠rue（默認(rèn)flase）

到此這篇關(guān)于Java 代碼實(shí)例解析設(shè)計(jì)模式之監(jiān)聽者模式的文章就介紹到這了,更多相關(guān)Java 設(shè)計(jì)模式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: