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メソッドで同期を使用することもできますが、このエラーをスローする並行コレクションを使用する方がはるかに簡単です。例:ConcurrentHashMap。

ところで:コレクションを反復処理するよりもコストがかかる可能性があるため、毎回スレッドを開始することはありません。スレッドプールを使用するか、現在のスレッドで実行します。


メソッドをこれに置き換えます

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()の呼び出しを同期していませんMaprun()複数のスレッドが同時に呼び出そうとすると、スローConcurrentModificationExceptionされますが、これがあなたの場合の理由です。

synced on run() を使用する必要がある場合があります (または) のような並行コレクションを使用する必要がある場合がありますConcurrentHashMap

于 2013-01-02T15:53:52.330 に答える