Python观察者模式

Posted 2022-12-14 追风弧箭

　　观察者模式有时也被称为发布/订阅模式，观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时，会通知所有观察者对象，使他们能够自动更新自己。

模式中的角色：
　　抽象主题(subject)：它把所有观察者对象的引用保存到一个聚集中，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者对象。
　　具体主题(concreteSubject)：将有关状态存入到具体观察者对象，在具体主题内部状态发生改变的时候，给所有登记过的观察者发出通知。
　　抽象观察者(observer)：为所有的具体观察者定义一个接口，在得到主题通知的时候更新自己。
　　具体观察者(concreteObserver)：实现抽象观察者所要求的更新接口，以便使得本身的状态与主题状态协调。

class Observer:
    def __init__(self,name,sub):
        self.name = name
        self.sub = sub

    def update(self):
        pass

class StockObserver(Observer):
    #no need to rewrite __init__()
    def Update(self):
        print "%s:%s,stop watching Stock and go on work!" %(self.name,self.sub.action)

class NBAObserver(Observer):
    def Update(self):
        print "%s:%s,stop watching NBA and go on work!" %(self.name,self.sub.action)

class SecretaryBase:
    def __init__(self):
        self.observers = []
    def Attach(self,new_observer):
        pass 
    def Notify(self):
        pass

class Secretary(SecretaryBase):
    def Attach(self,new_observer):
        self.observers.append(new_observer)
    def Notify(self):
        for p in self.observers:
            p.Update()

if __name__ == "__main__":
    p = Secretary()
    s1 = StockObserver("xh",p)
    s2 = NBAObserver("wyt",p)
    p.Attach(s1);
    p.Attach(s2);
    p.action = "WARNING:BOSS ";
    p.Notify()