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 回答