消费者<X>数组中的ArrayStoreException

问题描述

我要存储对BiConsumers<Integer,X>的引用，该引用适用于Consumer<Integer>：

public void setConsumer(BiConsumer<Integer,X> consumer) {
    fieldConsumer = integer -> consumer.accept(integer,fieldSubject);
}

但是我需要两个，所以我更改了代码以使用数组：

private Consumer<Integer>[] fieldConsumers;

public MyClass(int numberOfConsumers) {
    Consumer<Integer> consumer = integer -> {};
    fieldConsumers= (Consumer<Integer>[]) Array.newInstance(consumer.getClass(),numberOfObservers);
}

public void addConsumer(int consumerIndex,BiConsumer<Integer,X> consumer) {
    // Offending line
    fieldConsumers[consumerIndex] = responseType-> consumer.accept(responseType,fieldSubject);

}

以便可以通过以下方式触发回调：

for (Consumer<Integer> consumer: fieldConsumers) {
    consumer.accept(responseType);
}

我得到了错误：

java.lang.ArrayStoreException:

在此行：

fieldConsumers[consumerIndex] = responseType-> consumer.accept(responseType,fieldSubject);

现在，如果您仍在阅读本文，我还有一个问题：

如果我这样做的话，我仍然会保留对外部消费者的引用，而不是使用旧的fieldConsumers.add(consumer)，其中fieldConsumers是List<BiConsumer<Integer,X>>吗？

解决方法

您使用Array.newInstance(consumer.getClass(),numberOfObservers)创建了Consumer<Integer>[]数组。但是consumer.getClass()会返回您正在调用该方法的对象的实际类，该类始终是接口的实现类。此元素类型的数组只能保存相同具体类的对象，而不能保存接口的任意实现。

这与例如

没有什么不同

CharSequence cs = "hello";
CharSequence[] array = (CharSequence[]) Array.newInstance(cs.getClass(),1);
array[0] = new StringBuilder();

在这里，cs的类型为CharSequence，创建反射数组似乎可以创建类型为CharSequence[]的数组，因此应该可以存储StringBuilder。但是由于cs.getClass()返回实际的实现类String，所以该数组实际上是类型String[]，因此，尝试存储StringBuilder会产生一个ArrayStoreException。

在使用lambda表达式的情况下，事情会稍微复杂一些，因为功能接口的实际实现类是在运行时提供的，有意未指定。您使用了lambda表达式integer -> {}来在构造函数中创建数组，该数组的求值方法不同于responseType-> consumer.accept(responseType,fieldSubject)方法中的addConsumer实现类，在特定的运行时是。

此行为与描述最常用环境的行为的this answer一致。另外，其他实现可能表现出不同的行为，例如计算所有lambda表达式的特定功能接口的同一实现类。但是也可能是同一lambda表达式的多次求值会产生不同的类。

因此解决方法是使用预期的接口元素类型，例如

fieldConsumers=(Consumer<Integer>[])Array.newInstance(Consumer.class,numberOfObservers);

但是根本不需要创建反射数组。您可以使用：

fieldConsumers = new Consumer[numberOfObservers];

您无法编写new Consumer<Integer>[numberOfObservers]，因为不允许创建通用数组。这就是为什么上面的代码使用原始类型的原因。相反，使用Reflection并不能改善这种情况，因为这两种情况都是未经检查的操作。您可能需要为此添加@SuppressWarnings。更干净的选择是使用List<Consumer<Integer>>，因为它可以保护您免受数组和泛型的影响。

目前尚不清楚您所说的“提及外部消费者”是什么意思。在任何一种情况下，您都有对Consumer实现的引用，这些实现捕获对您作为BiConsumer的参数收到的addConsumer实现的引用。

arrays arrays consumer java java observer-pattern reference