我正在使用 google gauva 11.0.1 版并拥有这段代码:
ImmutableList.copyOf(items);
其中 items 是 ConcurrentLinkedQueue。我偶尔会看到这个错误:
java.lang.ArrayIndexOutOfBoundsException: 10
at java.util.AbstractCollection.toArray(AbstractCollection.java:126)
at com.google.common.collect.ImmutableList.copyFromCollection(ImmutableList.java:278)
at com.google.common.collect.ImmutableList.copyOf(ImmutableList.java:247)
at com.google.common.collect.ImmutableList.copyOf(ImmutableList.java:217)
鉴于问题完全出在番石榴库中,有人知道为什么吗?
根据下面的正确答案更新
感谢 wolfcastle 的帮助,我设法在我的应用程序之外单独重现了这个问题。
final int itemsToPut = 30000;
final ConcurrentLinkedQueue<Integer> items = new ConcurrentLinkedQueue<Integer>();
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < itemsToPut; i++) {
items.add(i);
}
}
}, "putter-thread").start();
final Iterable<String> transformed = Collections2.transform(items, new Function<Integer, String>() {
public String apply(Integer integer) {
return "foo-" + integer;
}
});
ImmutableList.copyOf(transformed);
运行它每次都会产生以下结果:
Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: 21480
at java.util.AbstractCollection.toArray(AbstractCollection.java:126)
at com.google.common.collect.ImmutableList.copyFromCollection(ImmutableList.java:278)
at com.google.common.collect.ImmutableList.copyOf(ImmutableList.java:247)
at com.google.common.collect.ImmutableList.copyOf(ImmutableList.java:217)
为了在我的应用程序中解决,我找到了许多选项。
远离 Collections2
通过从 Collections2.transform 切换到 Iterables.transform,问题就消失了。
远离 Java 1.5
虽然这在我的情况下是不可能的,但我用 Java 1.6 和 Java 1.7 进行了尝试,问题就消失了。我怀疑这是由于 AbstractCollection.toArray() 从 1.5 的实现发生了变化:
1.5
public Object[] toArray() {
Object[] result = new Object[size()];
Iterator<E> e = iterator();
for (int i=0; e.hasNext(); i++)
result[i] = e.next();
return result;
}
1.6
public Object[] toArray() {
// Estimate size of array; be prepared to see more or fewer elements
Object[] r = new Object[size()];
Iterator<E> it = iterator();
for (int i = 0; i < r.length; i++) {
if (! it.hasNext()) // fewer elements than expected
return Arrays.copyOf(r, i);
r[i] = it.next();
}
return it.hasNext() ? finishToArray(r, it) : r;
}
先复制 ConcurrentLinkedQueue
对非线程安全的 Collection 执行转换显然远非理想。如果出于某种原因我不得不继续使用 Collections2.transform,我可以通过先获取项目集合的副本来解决问题。