/*根据sourceTableId查询数据*/ List<DlLineage> dlLineageList = getLineageListBySourceTableIds(null, null, Arrays.asList(451L)); /*源端数据处理*/ List<DlLineage> dlLineageListCopySource = new ArrayList<>(); Iterator<DlLineage> iterator = dlLineageList.iterator(); while (iterator.hasNext()) { /*获取源端的数据*/ if (iterator.next().getSourceLayer().equals(LayerTypeEnum.SOURCEEND.getCode())) { dlLineageListCopySource.add(iterator.next()); /*删除源端列表数据*/ dlLineageList.remove(iterator.next()); } }产生java.util.ConcurrentModificationException: null异常, if (iterator.next().getSourceLayer().equals(LayerTypeEnum.SOURCEEND.getCode()))出现问题并给出解决办法
时间: 2024-04-10 22:34:53 浏览: 90
产生`java.util.ConcurrentModificationException: null`异常是因为在使用迭代器遍历集合时,修改了集合的结构(删除了元素),导致迭代器失效。
问题出现在以下代码行:
```java
dlLineageList.remove(iterator.next());
```
解决办法是使用迭代器的 `remove()` 方法来删除元素,而不是直接使用集合的 `remove()` 方法。
以下是修正后的代码示例:
```java
Iterator<DlLineage> iterator = dlLineageList.iterator();
while (iterator.hasNext()) {
DlLineage dlLineage = iterator.next();
if (dlLineage.getSourceLayer().equals(LayerTypeEnum.SOURCEEND.getCode())) {
dlLineageListCopySource.add(dlLineage);
iterator.remove(); // 使用迭代器的 remove() 方法删除元素
}
}
```
通过使用迭代器的 `remove()` 方法来删除元素,可以避免 `ConcurrentModificationException` 异常的发生。
相关问题
/*根据sourceTableId查询数据*/ List<DlLineage> dlLineageList = getLineageListBySourceTableIds(null, null, Arrays.asList(451L)); /*源端数据处理*/ List<DlLineage> dlLineageListCopySource = new ArrayList<>(); Iterator<DlLineage> iterator = dlLineageList.iterator(); while (iterator.hasNext()) { /*获取源端的数据*/ if (iterator.next().getSourceLayer().equals(LayerTypeEnum.SOURCEEND.getCode())) { dlLineageListCopySource.add(iterator.next()); /*删除源端列表数据*/ dlLineageList.remove(iterator.next()); } } 将这段代码改编成dlLineageListCopySource 存放LayerTypeEnum.SOURCEEND.getCode())类型的数据,dlLineageList 只存放除了LayerTypeEnum.SOURCEEND.getCode())类型的数据
为了实现将 `dlLineageListCopySource` 存放 `LayerTypeEnum.SOURCEEND.getCode()` 类型的数据,`dlLineageList` 只存放除了 `LayerTypeEnum.SOURCEEND.getCode()` 类型的数据,可以对代码进行如下修改:
```java
List<DlLineage> dlLineageList = getLineageListBySourceTableIds(null, null, Arrays.asList(451L));
List<DlLineage> dlLineageListCopySource = new ArrayList<>();
Iterator<DlLineage> iterator = dlLineageList.iterator();
while (iterator.hasNext()) {
DlLineage dlLineage = iterator.next();
if (dlLineage.getSourceLayer().equals(LayerTypeEnum.SOURCEEND.getCode())) {
dlLineageListCopySource.add(dlLineage);
iterator.remove(); // 使用迭代器的 remove() 方法删除元素
}
}
```
这样修改后,`dlLineageListCopySource` 将只包含 `LayerTypeEnum.SOURCEEND.getCode()` 类型的数据,而 `dlLineageList` 将只包含除了 `LayerTypeEnum.SOURCEEND.getCode()` 类型的数据。注意在遍历时,只调用了一次 `iterator.next()` 方法,以避免重复获取元素。
优化以下代码: Set<Long> goodsCategoryId = new HashSet<>(); if (!CollectionUtils.isEmpty(goodsCategoryIds)) { Map<Long, CategoryCache> categoryMap2 = this.categoryService.categoryMap(tenantId, goodsCategoryIds); goodsCategoryIds.forEach(c -> { if (Objects.isNull(categoryMap2.get(c))) { return; } else { CategoryCache categoryCache1 = categoryMap2.get(c); String[] split = categoryCache1.getIdPaths().split("-"); List<String> strings = Arrays.asList(split); Set<Long> categoryId = strings.stream().map(Long::parseLong).collect(Collectors.toSet()); goodsCategoryId.addAll(categoryId); } }); }
可以优化的地方有:
1. 使用 lambda 表达式来简化代码。
2. 如果 goodsCategoryIds 不为空,则先获取 categoryMap2,避免重复获取。
3. 使用 containsKey 来判断 Map 中是否存在某个 key。
4. 将 split 和 Arrays.asList(split) 合并为一行代码。
5. 使用 flatMap 来将 List<Long> 转换为 Set<Long>。
6. 将 forEach 替换为 stream。
优化后的代码如下:
```
Set<Long> goodsCategoryId = new HashSet<>();
if (!CollectionUtils.isEmpty(goodsCategoryIds)) {
Map<Long, CategoryCache> categoryMap2 = this.categoryService.categoryMap(tenantId, goodsCategoryIds);
goodsCategoryIds.stream()
.filter(categoryMap2::containsKey)
.map(categoryMap2::get)
.map(CategoryCache::getIdPaths)
.map(idPaths -> Arrays.stream(idPaths.split("-")).map(Long::parseLong).collect(Collectors.toSet()))
.flatMap(Collection::stream)
.forEach(goodsCategoryId::add);
}
```
阅读全文