我有一个Java类,被很多线程同时访问,我想确保它是线程安全的。这个类有一个私有字段,它是一个字符串到字符串列表的映射。我已经将该映射实现为ConcurrentHashMap,以确保获取和放置操作是线程安全的:
public class ListStore {
private Map<String, List<String>> innerListStore;
public ListStore() {
innerListStore = new ConcurrentHashMap<String, List<String>>();
}
...
}
考虑到对Map的gets和puts是线程安全的,我的关注点在于存储在Map中的列表。例如,考虑以下方法,该方法检查给定列表中是否存在给定条目(为简洁起见,我省略了错误检查):
public boolean listEntryExists(String listName, String listEntry) {
List<String> listToSearch = innerListStore.get(listName);
for (String entryName : listToSearch) {
if(entryName.equals(listEntry)) {
return true;
}
}
return false;
}
似乎我需要同步此方法的整个内容,因为如果另一个方法在此方法迭代期间更改innerListStore.get(listName)列表的内容,则会抛出ConcurrentModificationException异常。 如果是这样,请问我应该在innerListStore上同步还是在本地变量listToSearch上同步呢?
更新:感谢您的回复。听起来我可以在列表本身上同步。有关更多信息,请参见add()方法,该方法可以同时在另一个线程中运行listEntryExists()方法。
public void add(String listName, String entryName) {
List<String> addTo = innerListStore.get(listName);
if (addTo == null) {
addTo = Collections.synchronizedList(new ArrayList<String>());
List<String> added = innerListStore.putIfAbsent(listName, addTo);
if (added != null) {
addTo = added;
}
}
addTo.add(entryName);
}
如果这是唯一修改存储在地图中的基础列表的方法,并且没有公共方法返回对地图或地图中条目的引用,那么我可以在列表本身上同步迭代吗?这个add()的实现是否足够?
add()
实现有问题。你需要正确处理putIfAbsent()
的结果(否则可能会添加到错误的列表中)。 - jtahlbornputIfAbsent()
方法的文档(注意该方法的名称)。 - jtahlborn