14

相关: java是否有“LinkedConcurrentHashMap”数据结构?


我正在寻找一个集合类来保存对事件侦听器的引用。

理想情况下,我希望该集合具有以下属性(按优先级排序):

  1. 维护插入顺序。较早的侦听器可能会取消该事件,从而阻止它被传递给后来添加的侦听器。如果使用诸如HashSet其迭代器可能以错误顺序返回元素的类,这将中断。
  2. 使用WeakReferences 以便侦听器列表不会阻止侦听器被垃圾收集。
  3. 该集合是 a Set,因此会自动删除重复项。
  4. Iterator是集合的线程安全快照,不受添加新侦听器的影响。还允许在多个线程上传递事件。(这不是必需的 - 我可以迭代该集合的克隆。)

我知道一些类满足了部分但不是所有这些标准。例子:

  • java.util.LinkedHashSet(#1和#3)
  • java.util.WeakHashMapCollections.newSetFromMap, 由(#2 和 #3)包裹
  • javax.swing.event.EventListenerList(需要一些额外的同步)(#1和#4)
  • java.util.concurrent.CopyOnWriteArraySet(#1、#3 和 #4)

但是#1和#2都没有。这样的类是否存在于某个图书馆中?

4

5 回答 5

7

我首先要说的是,您有几个要求放在一起没有意义。您正在寻找一个删除重复项并支持弱引用的集合,这向我表明侦听器可能会在不确定的时间出现和消失。然而,您想保持插入顺序,并允许一个侦听器取消所有后续通知。对我来说,这听起来像是很难找到错误的秘诀,我强烈建议重新考虑它。

也就是说,您有一个几乎驱动解决方案的要求:您不希望ConcurrentModificationException来自普通迭代器的那个。这意味着您将不得不复制原始列表。在此过程中,您可以检查并删除空引用:

// the master list
List<WeakReference<MyListener>> _list = new ArrayList<WeakReference<MyListener>>();

// inside your send-notification method
List<MyListener> toNotify = new ArrayList<MyListener>(_list.size());
Iterator<WeakReference<MyListener>> itx = _list.iterator();
while (itx.hasNext())
{
    WeakReference<MyListener> ref = itx.next();
    MyListener lsnr = ref.get();
    if (lsnr != null)
        toNotify.add(lsnr);
    else
        itx.remove();
}

// now iterate "toNotify" and invoke the listeners

你现在可能吓坏了,说“一个列表!这是一个线性数据结构!我不能使用它,插入是 O(N)!”

嗯,是的,你可以。我不知道你打算有多少听众。但只要你 < 100(更可能 < 100,000),插入和删除的线性搜索成本就无关紧要了。

从编码的角度来看,更有趣的是如何处理弱引用。您会注意到,在测试所指对象是否为空之前,我将其显式取消引用到一个变量中。在处理引用对象时,这是非常重要的代码:尽管在两次调用之间收集引用对象的可能性极小get(),但这是可能的。

这让我想到了WeakReference它本身。您需要创建自己的子类来覆盖equals()hashCode()方法以委托给它的所指对象。我以为我只有这样一个类,但显然没有,所以将它留给你实现。

于 2010-01-18T13:37:31.527 回答
7

您可以使用 Wea​​kListeners(参见http://bits.netbeans.org/dev/javadoc/org-openide-util/org/openide/util/WeakListeners.html)和 CopyOnWriteArraySet。

  1. remove(ListenerType listener)在您的事件源中实现一个方法。
  2. 在您的register(SomeListener listener)方法中,将 WeakListener 添加到集合中:

    listenerCollection.put((ListenerType)WeakListeners.create ( ListenerType.class, listener, this));

当真正的监听器从内存中移除时,弱监听器会被通知,并且它会注销自己。(这就是为什么它需要引用源(this)进行注册。)取消注册是通过调用源的方法 remove 使用反射完成的。

于 2010-01-18T15:34:39.400 回答
1

Set 是与侦听器一起使用的正确集合。

如果您依赖听众的插入顺序,您的设计就会被破坏。它错过了听众与其他听众隔离和独立的观点。使用集合而不是列表。

如果你依赖 WeakReferences,你的设计就会被破坏。在您添加它的同一对象中删除侦听器。此 SYMMETRY 支持 READABILITY 和 MAINTAINABILITY。要解决具有弱引用的侦听器忘记取消订阅的编程错误,只会隐藏问题。

如果您将您的侦听器集合提供给其他对象而不是您观察到的对象,那么您的设计就会被破坏。保持 Set 私有以支持 ENCAPSULATION。

如果您覆盖侦听器的 equals 和哈希码,您的设计就会被破坏。它隐藏了不必要的函数调用的问题。而是防止不必要的呼叫。毕竟,不需要覆盖侦听器的等号和哈希码。

在 MULTITHREADING 环境中,在资源“侦听器”上放置一个 MONITOR,同时添加、删除或迭代它。您可以在迭代之前创建一个防御副本以避免 ConcurrentModificationException。那么迭代不必是同步的,但复制动作应该是同步的。

必须调整或重新制定任何其他要求以匹配这些陈述。任何其他的做法都会因为缺乏隔离、独立、封装和清晰度而导致代码不可维护、内存泄漏。

于 2015-04-27T18:27:04.150 回答
0

您可以将每个侦听器引用包装在WeakReference中,然后使用CopyOnWriteArraySet

于 2010-01-15T15:49:29.547 回答
0

您可以扩展 WeakReference 以覆盖等于和哈希码,然后您可以在 LinkedHashSet 中使用它们。

于 2010-01-18T12:49:07.013 回答