我的应用程序在带有 Spring 和 Hibernate 框架的 tomcat 上运行。它使用 EHCache 作为服务级别的缓存提供者。这意味着由服务类创建的对象被放入缓存中。 (不是 hibernate Dao 对象)。
这些缓存对象中有一些集合对象(HashSet、ArrayList、HashMap)。它们都不是同步集合。都不是线程安全的,但放入缓存后不会被应用程序修改。
当我遍历这个集合时,我在很多情况下都发现了无限循环。有些循环是 Iterator 循环,有些是基于 int 索引运行的旧 for 循环。
通过用 Collections.synchronizedSet(new HashSet()) 替换 HashSet,我设法克服了一个无限循环。但我不明白使用普通 HashSet 的真正问题,因为应用程序永远不会修改它。 (EHCache 是否修改它们?)
如果这里使用非线程安全集合有任何问题,请向我解释。
public class HotelDetails implements Serializable { /*Objects in the cache */
private static final long serialVersionUID = 1L;
.....
private Set<String> facilities = new HashSet<String>();
}
以下循环无限运行并炸毁堆
if (hotelDetails.getFacilities() != null && hotelDetails.getFacilities().size() > 0) {
for (String fac : hotelDetails.getFacilities()) {
TFacility f = of.createTFacility();
f.setCode(fac);
f.setValue(fac);
facilities.getFacility().add(f);
}
}
一次替换HashSet,问题解决
public class HotelDetails implements Serializable { /*Objects in the cache */
private static final long serialVersionUID = 1L;
.....
private Set<String> facilities = Collections.synchronizedSet(new HashSet<String>());
}
这是另一个
private int getRatesStartIndex(GsRoomRate gsRoomRate, List<GsRate> gsRates, Date travelStart) {
Integer startIndex = gsRoomRate.getGsRateIndexes().get(travelStart);
if (startIndex==null) {
for (startIndex=0; startIndex<gsRates.size(); startIndex++) {
GsRate gsRate = gsRates.get(startIndex);
if (travelStart.between(gsRate.getStartDate(), gsRate.getEndDate())) {
gsRoomRate.getGsRateIndexes().put(travelStart, startIndex);
break;
}
}
if (startIndex>=gsRates.size()) startIndex = 0;
}
return startIndex;
}
public class GsRoomRate implements Serializable { /*Objects in the cache */
private static final long serialVersionUID = 1L;
private List<GsRate> gsRates = new ArrayList<GsRate>();
private Map<Date, Integer> gsRateIndexes = new HashMap<Date, Integer>();
}
public class GsRate implements Serializable { /*Objects in the cache */
private static final long serialVersionUID = 1L;
private RBADate startDate;
private RBADate endDate;
}
最佳答案
EHCache 不会以任何方式修改您的对象。有一个异常(exception):如果您有一个基于磁盘的缓存(即可以溢出到磁盘的缓存),那么 EHCache 将序列化您的对象,将它们写入磁盘并在需要时再次加载它们。
因此,如果序列化您的对象时出现问题并且您已将 EHCache 配置为溢出,这可能会导致问题,但感觉这不是您的问题。
我的猜测是几个具有相同ID的对象被放入缓存或者对象在完全初始化之前被添加到缓存。
如何调试?
使用
Collections.unmodifiable*()
可以在有人试图在将集合添加到缓存后对其进行修改时出错。保存集合的
hashCode()
并验证它。如果 a) 集合发生变化或 b) 如果集合中某个对象的hashCode()
发生变化,则hashCode()
会发生变化。
尤其是后者是不可预见问题的一个很好的来源:人们在 hashCode() 中使用非最终字段,将对象添加到集合/映射中,然后发生奇怪的事情。
关于java - 多线程环境中缓存集合的无限循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7363090/