0 
private static HashMap<String, FileInfo> sFileInfoObjectList = new CacheLinkedHashMap<String, FileInfo>();

public static synchronized FileInfo getFileInfoForProvider(...) {
 FileInfo foundFileInfo = null;

 (...)

 foundFileInfo = sFileInfoObjectList.get(hashEntryKey);

 (...)

 sFileInfoObjectList.put(hashEntryKey, foundFileInfo);

 (...)
}

public static synchronized void removeFileInfoForProvider(final int providerId) {
    Thread thread = new Thread() {
        @Override
        public void run() {
            Iterator<Entry<String, FileInfo>> it = sFileInfoObjectList.entrySet().iterator();
            while (it.hasNext()) {
                Entry<String, FileInfo> pair = it.next();
                FileInfo info = pair.getValue();
                if (providerId == info.mProvider) {                            
                    it.remove();
                }
            }
        }
    };
}

我在 run() 方法中收到 ConccurentModificationException。我尝试了以下，但没有奏效：

public void run() {
    synchronized(sFileInfoObjectList) {
        Iterator<Entry<String, FileInfo>> it = sFileInfoObjectList.entrySet().iterator();
        while (it.hasNext()) {
            Entry<String, FileInfo> pair = it.next();
            FileInfo info = pair.getValue();
            if (providerId == info.mProvider) {                            
                it.remove();
            }
        }
    }
}
4

2 回答 2

2

run() 不在同步块中，因为它在另一个线程上运行。您可以在 run 方法中使用同步，但使用会引发此错误的并发集合会简单得多。例如并发哈希映射。

顺便说一句：我不会每次都启动一个线程，因为它可能比迭代集合更昂贵。我会使用线程池，或者在当前线程中执行。

用这个替换你的方法

public static void removeFileInfoForProvider(final int providerId) {
    Thread thread = new Thread() {
        @Override
        public void run() {
            removeFileInfoForProvider0(providerId);
        }
    };
    thread.start();
}

static synchronized void removeFileInfoForProvider0(final int providerId) {
    Iterator<Entry<String, FileInfo>> it = sFileInfoObjectList.entrySet().iterator();
    while (it.hasNext()) {
        Entry<String, FileInfo> pair = it.next();
        FileInfo info = pair.getValue();
        if (providerId == info.mProvider) {                            
            it.remove();
        }
    }
}
于 2013-01-02T15:55:27.463 回答
0

您尚未同步remove()调用Map. 如果多个线程尝试同时调用run()，它将抛出ConcurrentModificationException这就是您的情况的原因。

您可能需要在 run() 上使用同步（或）使用并发集合，例如ConcurrentHashMap

于 2013-01-02T15:53:52.330 回答