使用Jena execConstruct时出现ConcurrentModificationException的安全代码实现咨询

这个问题我之前在使用Jena的时候也踩过坑，核心原因很明确：你在调用execConstruct(model)时直接传入了原有的model对象，而Jena执行Construct查询的过程中，会同时对同一个model进行读（查询原数据）和写（添加构造出的新三元组）操作，这种并发的读写冲突就触发了ConcurrentModificationException——毕竟大多数集合类（包括Jena的Model实现）都不允许在遍历/读取的同时修改自身。

下面给你两种始终安全的代码写法，根据你的需求选就行：

方案一：用新Model接收查询结果（推荐） #

最稳妥的方式是完全分离读写操作：原model只负责提供查询数据源，新建一个空model来接收Construct的结果。这样两个model各司其职，不会有任何冲突。而且我建议用try-with-resources来管理QueryExecution，它能自动帮你释放资源，避免手动关闭遗漏的问题：

Query query = QueryFactory.create(queryString);
// try-with-resources自动关闭QueryExecution
try (QueryExecution qexec = QueryExecutionFactory.create(query, model)) {
    Model resultModel = ModelFactory.createDefaultModel();
    qexec.execConstruct(resultModel);
    System.out.println(resultModel.toString());
} finally {
    model.close();
}

方案二：将结果合并回原Model（如果必须） #

如果你确实需要把Construct的结果合并到原model里，不要直接写入原model，而是先把结果写到临时model中，完成查询后再一次性合并到原model。这样读写操作是串行执行的，不会出现并发冲突：

Query query = QueryFactory.create(queryString);
try (QueryExecution qexec = QueryExecutionFactory.create(query, model)) {
    Model tempModel = ModelFactory.createDefaultModel();
    qexec.execConstruct(tempModel);
    // 先完成查询写入临时Model，再合并到原Model
    model.add(tempModel);
    System.out.println(model.toString());
} finally {
    model.close();
}

额外注意点 #

• 永远记得正确关闭QueryExecution和Model：try-with-resources是JDK7+的特性，对实现了AutoCloseable接口的类（比如Jena的QueryExecution）非常友好，能避免资源泄漏。
• 不要在遍历Model、执行查询的过程中修改同一个Model的内容，这是Java集合类和RDF框架的通用禁忌，本质都是并发修改的问题。

内容的提问来源于stack exchange，提问作者Discipulos