在Python中“删除”主题后,使用观察者模式删除观察者

里克支持莫妮卡

我正在尝试在python中实现一个非常简单的观察者模式

这是我的Observer课程(它实际上只是一个接口,我想我实际上并不需要它):

class Observer():
    def update(self,subject,message): pass

我的Subject课(又名Observable,但我更喜欢Subject):

class Subject():
    def __init__(self):
        self.observers = []
    def registerObserver(self, observer):
        if observer not in self.observers:
            self.observers.append(observer)
    def removeObserver(self, observer):
        self.observers.remove(observer)
    def notifyObservers(self, message = None):
        for observer in self.observers:
            observer.update(self,message)

A包含一个嵌套DelNotifier类,它是的子类SubjectA删除一个类对象(实际上是由于__del__方法中的垃圾收集)时,该想法A.DelNotifier将通知所有其删除者。

class A():
    def __init__(self, name):
        self.name = name
        self.delNotifier = A.DelNotifier(self)
    class DelNotifier(Subject):
        def __init__(self, outer):
            super(A.DelNotifier,self).__init__()
            self.outer = outer
        def notifyObservers(self):
            Subject.notifyObservers(self,"This is Class A object " + self.outer.name + ": I'm dying!")
    def registerB(self,observer):
        if not isinstance(observer,B): raise ValueError("Can only register Class B objects with Class A.")
        self.delNotifier.registerObserver(observer.Aobserver)
    def deleteme(self):
        print("Must notify observers of my impending doom first...")
        self.delNotifier.notifyObservers()
    def __str__(self):
        return "Class A object " + self.name
    def __del__(self):
        self.deleteme()
        print("Done notifying everyone, time to go gentle into that good night.")

B包含一个嵌套的AObserver类,它是的子类,删除Observer,它将接收来自类A.DelNotifier主题的消息A(同样,实际上,这是在A对象被垃圾回收时发生的):

class B():
    def __init__(self, name, a):
        self.name = name
        self.Aobserver = B.AObserver(self)
        a.registerB(self)
    class AObserver(Observer):
        def __init__(self,outer):
            super(B.AObserver,self).__init__()
            self.outer = outer
        def update(self,subject,message):
            print(str(self.outer) + " received message: '" + str(message) + "'")
            print("Time for", self.outer, "to die, too.")
            self.outer.__del__()
    def __str__(self):
        return "Class B object " + self.name
    def __del__(self):
        print("This is " + str(self) + ": now I'm dying, too!")

这种设计在我__del__()直接调用时有效,但是,当会话退出时,某些对象似乎再次被gc了:

>>> a = A('a')
>>> b1 = B('b1', a)
>>> b2 = B('b2', a)
>>> a.__del__()
Must notify observers of my impending doom first...
Class B object b1 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b1 to die, too.
This is Class B object b1: now I'm dying, too!
Class B object b2 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b2 to die, too.
This is Class B object b2: now I'm dying, too!
Done notifying everyone, time to go gentle into that good night.
>>> exit()
Must notify observers of my impending doom first...
Class B object b1 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b1 to die, too.
This is Class B object b1: now I'm dying, too!
Class B object b2 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b2 to die, too.
This is Class B object b2: now I'm dying, too!
Done notifying everyone, time to go gentle into that good night.
This is Class B object b1: now I'm dying, too!
This is Class B object b2: now I'm dying, too!

我认为这更重要的另一个问题是,当我从列表中选择del一个类A项目时,该项目不会立即被垃圾回收,而且我不能确定B是否已删除任何注册的项目:

>>> b1 = B('b1',a[0])
>>> b2 = B('b2',a[0])
>>> del a[0]
## Note that items are not deleted until session exits
>>> exit()
Must notify observers of my impending doom first...
Class B object b1 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b1 to die, too.
This is Class B object b1: now I'm dying, too!
Class B object b2 received message: 'This is Class A object a: I'm dying!'
Time for Class B object b2 to die, too.
This is Class B object b2: now I'm dying, too!
Done notifying everyone, time to go gentle into that good night.
##Note that the class B objects get gc'd a second time....???
This is Class B object b1: now I'm dying, too!
This is Class B object b2: now I'm dying, too!

除了这些问题之外,我还知道依赖于__del__方法对对象进行gc'd后清理对象以外的任何其他工作所固有的许多问题,出于我尝试的目的,应该避免使用该对象聘请。但是我不知道另一种方式。

有什么更好的方法可以做到这一点?我已经考虑过在使用完内容后尝试使用上下文管理器(with)删除内容,但是我没有这样做的经验。如果那将是一个不错的选择,我将如何去做呢?它会是什么样子?

编辑:澄清所需的行为

我将尝试消除一些(可理解的)混乱。

我已经在上面简化了一些代码,但这B是一个依赖于object的对象A如果一个BA消失,这B应该消失。我将有一些Alist和B的容器(在此处使用):

As = [A('a'+str(i)) for i in range(10)]
Bs = [B('b'+str(i),As[i]) for i in range(10)] #Bs made of As
del As[0] #whoops, don't need As[0] anymore
assert Bs[0] is None #ERROR!
#or using pop:
As.pop(0)
assert Bs[0] is None #ERROR!

请参阅前几天我的上一个问题,该问题帮助我领会了首先使用观察者模式的整个想法。

cod3monk3y

这是很大的代码差异,可以满足您自动维护引用列表以及删除引用时进行清理的要求。我添加了一个Manager类来完成此操作,并添加了第二个通过deleted()事件,该事件是Manager清理其维护的列表的一个钩子。我将在此处重新发布完整的,经过修改的代码,因为更新我以前的答案并不容易。

我相信这完全可以满足您提出的问题。也许不是这个原因,为什么你需要这个摆在首位,但我想你问的是,在其他问题。

我们需要薄弱的参考才能完成这项工作:

import weakref

Observer接口得到了被称为新方法后, deleted()

class Observer(object):
    def update(self,subject,message): pass

    def deleting(self,subject):
        ''' the subject is being deleted '''
        pass

    def deleted(self,subject):
        pass

经理班级维护主题和观察员的列表

class Manager(Observer):

    def __init__(self, ):
        self._subjects = []
        self._observers = []

    def monitorSubject(self, subject):
        self._subjects.append( weakref.ref(subject) )

        # observe the subject for deletion to
        # trigger list maintenance on "deleted"
        subject.registerObserver(self)

    def monitorObserver(self, observer):
        self._observers.append( weakref.ref(observer) )

    def deleted(self, subject):
        ''' a subject was deleted, remove it from the list.
        deleting() is called first, and the observers delete themselves.
        deleted() is called next, and is a hook for the manager to
        cleanup any dead subjects and observers '''

        # calling a weakref returns the original object, and `None` when the
        # reference is dead
        def isNotDead(r):
            return not r()==None

        # remove any dead subjects
        print 'Removing dead subjects...'
        self._subjects = filter(isNotDead, self._subjects)

        # remove any dead observers            
        print 'Removing dead observers...'
        self._observers = filter(isNotDead, self._observers, )

    def __str__(self,):
        return "[Manager] Subjects:{0}, Observers:{1}".format(
            ','.join([str(r()) for r in self._subjects]),
            ','.join([str(r()) for r in self._observers])
        )

注释中指出了主题上的差异,但主要是需要第二遍deleted第一遍deleting通知观察者,第二遍deleted通知管理者。另外,该__del__例程使用弱引用进行迭代,因为其中一些在此过程中会被删除。

class Subject(object):
    def __init__(self):
        self.observers = []

    def __del__(self, ):
        ''' on deletion, notify the observers '''
        print "{0}.__del__".format(self)

        # copy the observer list, then remove all references to the observers
        # NEW - use weakrefs here, or they will not be properly deleted later
        obs = [weakref.ref(o) for o in self.observers]

        # clear all strong references to the observers
        self.observers = []

        # notify all observers that we were deleted
        # ** only if they are not already deleted **
        for o in obs:
            if not o() == None:
                o().deleting(self)

        # NEW - second pass to allow the Manager to cleanup
        # ** only if they are not already deleted **
        for o in obs:
            if not o() == None:
                o().deleted(self)

    def registerObserver(self, observer):
        if observer not in self.observers:
            self.observers.append(observer)

    def removeObserver(self, observer):
        self.observers.remove(observer)

    def notifyObservers(self, message = None):
        for observer in self.observers:
            observer.update(self,message)

与以前相同,只是简化了字符串格式

class A(Subject):
    ''' A is just a subject '''
    def __init__(self, name):
        super(A,self).__init__()
        self.name = name

    def __str__(self):
        return "A[ {0} ]".format(self.name)

B和以前一样

class B(Observer):
    ''' class B is an observer of A '''

    def __init__(self, name, a):
        self.name = name

        # don't keep a reference to 'a', or 'a' will not be deleted!
        a.registerObserver(self)

    def __str__(self):
        return "B[ {0} ]".format(self.name)

    def __del__(self):
        print("{0}.__del__".format(self))

    def deleting(self, subject):
        ''' notification from the subject (A) that it is being deleted. I'm
        assuming here that the subject is actually the one we registered in
        __init__, since I couldn't store a reference or else __del__ would
        not have been called! '''
        print "B[{0}].deleting, subject={1}".format(self.name, subject)

        del self

一些执行文件的代码:

if __name__ == '__main__':

    mgr = Manager()

    # keep strong references to the subjects, because
    # we will delete them explicitly
    a1 = A('a1')
    a2 = A('a2')
    mgr.monitorSubject(a1)
    mgr.monitorSubject(a2)

    # monitor observers directly, and do NOT keep
    # strong references or they will not be deleted
    mgr.monitorObserver( B('b1', a1) )
    mgr.monitorObserver( B('b2', a1) )
    mgr.monitorObserver( B('b3', a2) )
    mgr.monitorObserver( B('b4', a2) )

    # show the starting state
    print mgr

    print "Deleting a1..."
    del a1
    print mgr

    print "Deleting a2..."
    del a2
    print mgr

并输出:

    #  OUTPUT (some newlines added)
    #
    #  [Manager] Subjects:A[ a1 ],A[ a2 ], Observers:B[ b1 ],B[ b2 ],B[ b3 ],B[ b4 ]
    #
    #  Deleting a1...
    #  A[ a1 ].__del__
    #  B[ b1 ].__del__
    #  B[ b2 ].__del__
    #  Removing dead subjects...
    #  Removing dead observers...
    #  [Manager] Subjects:A[ a2 ], Observers:B[ b3 ],B[ b4 ]
    #
    #  Deleting a2...
    #  A[ a2 ].__del__
    #  B[ b3 ].__del__
    #  B[ b4 ].__del__
    #  Removing dead subjects...
    #  Removing dead observers...
    #
    #  [Manager] Subjects:, Observers:

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

在Ember组件中删除观察者

来自分类Dev

在iOS中删除观察者

来自分类Dev

在Firebase中更改值后删除观察者

来自分类Dev

观察者模式-删除主题(何时垃圾收集器删除了主题)

来自分类Dev

Java观察者模式-如何在更新(通知)循环/迭代期间删除观察者?

来自分类Dev

在firebase中,如何删除所有观察者,而不是特定参考的观察者

来自分类Dev

观察者与主题的耦合

来自分类Dev

如何安全删除观察者(Swift)

来自分类Dev

iOS如何正确删除观察者

来自分类Dev

CFNotificationCenterRemoveEveryObserver不删除观察者

来自分类Dev

iOS NSNotificationCenter观察者未删除

来自分类Dev

C#中的观察者模式

来自分类Dev

MVP中的观察者模式

来自分类Dev

在反向导航中从单元中删除观察者

来自分类Dev

并发观察者模式

来自分类Dev

通用观察者模式

来自分类Dev

观察者交流模式

来自分类Dev

并发观察者模式

来自分类Dev

JS观察者模式

来自分类Dev

如何从阵列列表中删除__ob__:观察者?

来自分类Dev

从 NSNotification 中删除 C++ 观察者?

来自分类Dev

不同观察值的观察者模式

来自分类Dev

观察者模式:独立观察属性

来自分类Dev

删除对象后,观察者仍保留在调度表中

来自分类Dev

iOS在存在观察者之前删除观察者会引发异常

来自分类Dev

iOS在存在观察者之前删除观察者会引发异常

来自分类Dev

如何使用Magento中的观察者从产品网格中删除MassAction

来自分类Dev

如何使用Magento中的观察者从产品网格中删除MassAction

来自分类Dev

什么时候最好使用UICollectionViewCell从属性中删除观察者?