ConcurrencyException

Question

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(); 
      } 
     } 
    } 
} 

Answer 1

運行（）不是一個synchronized塊，因爲它是另一個線程上運行。你可以在你的run方法中使用synchronized，但是使用併發的集合會引起這個錯誤會更簡單。例如。 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(); 
     } 
    } 
} 

Answer 2

您還沒有同步remove()呼籲Map。如果多個線程同時嘗試撥打run()，它將拋出ConcurrentModificationException這是您的情況的原因。

您可能需要使用或者在運行同步（）（或）使用併發收集像ConcurrentHashMap