java.util.ConcurrentModificationException при перемещении jMapViewer

Question

Я пытаюсь обновлять маркеры на jMapViewer один раз каждые 5 секунд. Кажется, это работает нормально, пока вы не переместите карту. В этот момент он выбрасывает java.util.ConcurrentModificationException.

Я считаю, что это связано с различными процессами, пытающимися получить доступ к списку маркеров карт одновременно, но я не уверен, как это исправить.

timer.scheduleAtFixedRate(new TimerTask() { 
     @Override 
     public void run() { 
      loadUnits(); 
     } 
    }, 5 * 1000, 5 * 1000); 

    private void loadUnits() {  
    String query = "SELECT callsign, currentlat,currentlon,previouslat,previouslon, mobile, uniticon FROM unit WHERE isdeleted=0;"; 
    rs = DBase.runQuery(query); 
    kit.removeAllMapMarkers(); 
    MapMarkerUnit x; 
    try { 
     while (rs.next()) { 
      x = new MapMarkerUnit(rs.getDouble("currentlat"),rs.getDouble("currentlon")); 
      if (rs.getInt("mobile") == 1) x.setMovement(true); 
      else x.setMovement(false); 
      x.setIconName(rs.getString("uniticon")); 
      x.setPriority(1); 
      kit.addMapMarker(x); 
     } 
    } 
    catch (SQLException e) { 
     System.out.print(e.toString()); 
    } 
} 

Благодарим за помощь.

Киран

Answer 1

Вы можете сделать это с помощью Semaphore, Mutex, а монитор (с synchronized в подписи метода) или замок (synchronize на объекте). Существует lock-free и wait-free также подходит, но эти алгоритмы более сложны и полезны только при особых обстоятельствах.

---

Примеры

проблема, вероятно, что map модифицируется одновременно, используя замок, можно записать:

synchronize(map) { 
    map.removeAllMapMarkers(); 
    MapMarkerUnit x; 
    try { 
     while (rs.next()) { 
      x = new MapMarkerUnit(rs.getDouble("currentlat"),rs.getDouble("currentlon")); 
      if (rs.getInt("mobile") == 1) x.setMovement(true); 
      else x.setMovement(false); 
      x.setIconName(rs.getString("uniticon")); 
      x.setPriority(1); 
      map.addMapMarker(x); 
     } 
    } 
    catch (SQLException e) { 
     System.out.print(e.toString()); 
    } 
} 

Это приводит к тому, что только один Thread может получить доступ к map (если он запускает этот код). Если один поток находится в блоке synchronize, все остальные потоки ждут в начале блока.

Проблема с этим подходом - так называемая проблема Readers-Writers. Большинство хранилищ данных можно читать несколькими Читателями, но если некоторые Thread хотите что-то написать (изменить что-то тоже), no Reader может быть активным. В этом случае один использует ReadWriteLock:

private ReadWriteLock rwl = new ReentrantReadWriteLock(); 

public void writeSomething() { 
    rwl.writeLock().lock(); 
    try { 
     //Modify/write something 
    } finally { 
     rwl.writeLock().unlock(); 
    } 
} 

public String readSomething() { 
    rwl.readLock().lock(); 
    try { 
     //Read something 
    } finally { 
     rwl.readLock().unlock(); 
    } 
} 

Лучше использовать finally блоки так, что даже если Exception брошено вы все еще разблокировать замок, в противном случае никакой другой объект не сможет войти в критическую секцию.