6

我在 python 中实现了一个观察者可观察的模式：

这是 Observable 类：

class Observable(object):
    def __init__(self, value):
        self.value = value
        self.observers = []

    def set(self, value):
        old = self.value
        self.value = value
        self.notifyObservers(old, self.value)

    def get(self):
        return self.value

    def addObserver(self, o):
        self.observers.append(o)

    def removeObserver(self, o):
        if o in self.observers:
            self.observers.remove(o)

    def notifyObservers(self, old, new):
        for o in self.observers:
            o.valueChanged(old, new)

这是一个观察者：

class Observer(object):
    def __init__(self, foo):
        self.foo = foo
        self.foo.addObserver(self)

    def __del__(self):
        print('Observer.__del__ called')
        self.foo.removeObserver(self)

    def valueChanged(self, old, new):
        print('foo changed from %s to %s' % (old, new))

该代码按预期工作。

但我需要将Observer其销毁（即，当它未被引用时，它应该从Observable对象中的观察者列表中删除自己）。

问题是，使用此代码，如果在某个对象的观察者列表中，Observer.__del__则永远不会被调用。ObserverObservable

请注意，我不一定要Observer显式销毁它，它也会因为变量赋值而未被引用，因此removeObserver()在销毁之前显式调用是不可行的。

如果我注释掉self.foo.addObserver(self)，那么就没有额外的引用Observer，并且调用del它会调用Observer.__del__.

这个场景的测试用例是：

foo = Observable(23)
bar = Observer(foo)
foo.set(44)
bar = None
foo.set(1)

它有两个结果：

  • 如果self.foo.addObserver(self)没有被注释掉，它会打印foo changed from 23 to 44并foo changed from 44 to 1
  • 如果self.foo.addObserver(self)被注释掉，它会打印Observer.__del__ called
4

2 回答 2

5

似乎弱引用将解决您的问题。您可以更改观察者来管理弱引用，例如，通过替换lista 中的weakref.WeakKeyDictionary，或通过实现一些其他弱引用容器。顺便说一句，使用散列类型（例如字典）也将比列表更好，因为删除观察者会更有效。

于 2016-11-22T11:52:08.883 回答
1

解决方案：（Observable.observers改为weakref.WeakKeyDictionary）

class Observable(object):
    def __init__(self, value):
        self.value = value
        self.observers = weakref.WeakKeyDictionary()

    def set(self, value):
        old = self.value
        self.value = value
        self.notifyObservers(old, self.value)

    def get(self):
        return self.value

    def addObserver(self, o):
        self.observers[o] = 1

    def removeObserver(self, o):
        del self.observers[o]

    def notifyObservers(self, old, new):
        for o in self.observers:
            o.valueChanged(old, new)

此外，不需要调用.removeObserver(self)观察者的析构函数。

于 2016-11-22T21:12:13.683 回答