您好,登錄后才能下訂單哦!
本篇內容主要講解“C++怎么發布訂閱和觀察者模式”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強。下面就讓小編來帶大家學習“C++怎么發布訂閱和觀察者模式”吧!
1、實現思路
arr 做訂閱了的事件的緩存中心
通過過on把需要做的事push arr 緩存數組中
等待事件觸發時 依次emit執行事件
2、代碼實現
interface eventHub { arr: Array<Function>; on(fn: Function): void; emit(): void; } interface Person { age: number; name: string; } let eventHub: eventHub = { arr: [] as Array<Function>, // 訂閱 on(fn: Function) { this.arr.push(fn); }, // 發布 emit() { this.arr.forEach((fn) => fn()); }, }; let person: Person = {} as Person; eventHub.on(() => { //訂閱的事件里判斷當 person長度為2時 打印person, if (Object.keys(person).length == 2) { console.log(person); } }); setTimeout(function () { person.age = 27; //發布的時候去遍歷 this.arr 并執行第一次 eventHub.emit(); }, 10); setTimeout(function () { person.name = "Zoe"; //發布的時候去遍歷 this.arr 并執行第二次 eventHub.emit(); }, 20);
3、結果
雖然發布了兩次 但最終on 里的console因為外部條件只執行了一次
1、實現思路
與觀察者模式類似,但需要分一個觀察者,和被觀察者
觀察者和被觀察者存在關聯,(內部基于發布訂閱模式)
2、代碼實現
// 被觀察者 class Subject { name: string; //實例上定義一個name屬性 state: string; observers: any[]; constructor(name:string) { this.name = name; this.observers = []; this.state = ""; } attach(o) { //傳入觀察者 this.observers.push(o); } setState(newState) { this.state = newState; this.observers.forEach((o) => o.update(this)); } } // 觀察者 class Observer { name: string; constructor(name) { this.name = name; } update(interviewee) { console.log(`${interviewee.name} say to: ${this.name} ZOE的${interviewee.state}`); } } let hr = new Subject("HR"); let observer1 = new Observer("內推者"); let observer2 = new Observer("面試者"); hr.attach(observer1); hr.attach(observer2); hr.setState("面試通過了"); // baby.setState("面試沒通過");
3、實現結果
on(訂閱)和發布(emit)之間沒有直接聯系,是依賴中間的arr 做銜接 訂閱一個push 到arr一個,emit的時候依次執行arr
觀察者和被觀察者存在關聯,(內部基于發布訂閱模式)
將觀察者的實例作參數 傳入被觀察者的attach方法中 并緩存在observers 數組中
當觀察者setState時候 依次調用緩存數組observers 中觀察者的update方法
到此,相信大家對“C++怎么發布訂閱和觀察者模式”有了更深的了解,不妨來實際操作一番吧!這里是億速云網站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續學習!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。