java.util.树图中的异常

Question

public class StoreMessage extends Thread implements Serializable{

    private static long start_nanotime=System.nanoTime();
    private static int timeToRun = 60000; 
    private static byte[] b=null;
    private static long startTime = System.currentTimeMillis();
    private static long runUntilMillis = System.currentTimeMillis() + timeToRun;
    public static Map <Long,Message> map1=new TreeMap<Long,Message>();

public static void store(Message message)throws Exception{
        while (true) {
            long now = System.currentTimeMillis();
            if (now >= runUntilMillis) {
               break;
            }
            long precise_time=TimeUnit.MILLISECONDS.toNanos(now)+(System.nanoTime()-start_nanotime);
            map1.put(precise_time, message);
           }
     }

public static byte[] returning()throws Exception
    { 

        b=serializer.serialize(map1);
        System.out.println(b);
        map1.clear();
        return b;


    }
}

我试图做的是，将StoreMessage类每一分钟接收到的所有消息对象存储到一个树映射中，序列化该树映射并将其返回给调用它的类，然后在下一分钟创建/清除树映射以存储其他消息对象
Message类的Message对象是jms文本消息，作为命令行参数输入。store方法在另一个类中调用，而returning（）方法在另一个类中调用。这两个类在实例化和运行时都有多个参数，这给了我一个异常

java.util.ConcurrentModificationException
at java.util.TreeMap$PrivateEntryIterator.nextEntry(TreeMap.java:1100)
at java.util.TreeMap$EntryIterator.next(TreeMap.java:1136)
at java.util.TreeMap$EntryIterator.next(TreeMap.java:1131)
at java.util.TreeMap.writeObject(TreeMap.java:2250)

为什么？尤其是在我清理地图的时候。如果我只给出一个命令行参数，我不会得到这个异常。但如果它被反复遵守，我会得到同样的例外<然后，当它们被序列化为消息时，它们被存储为trebr。当我希望树映射存储消息一分钟，然后序列化整个批次时。

Answer 1

从理论上讲，即使使用同步地图，也可能丢失一条消息。如果在系统运行时调用存储。出来正在进行println（）。这是在序列化之后但在清除之前。

所以我认为你可以在地图上同步（但我没有测试它）：

public static void store(Message message) throws Exception {
    while (true) {
        long now = System.currentTimeMillis();
        if (now >= runUntilMillis) {
            break;
        }
        long precise_time = TimeUnit.MILLISECONDS.toNanos(now)
                + (System.nanoTime() - start_nanotime);
        synchronized (map1) {
            map1.put(precise_time, message);
        }
    }
}

public static byte[] returning() throws Exception {

    synchronized (map1) {
        b = serializer.serialize(map1);
        System.out.println(b);
        map1.clear();
    }
    return b;
}

Answer 2

其他答案很接近，但我不相信它们是完整的。如果查看抛出的CME，它位于树映射迭代器中，即使将其设置为synchronizedMap，也不会使其成为线程安全的。在迭代期间，您仍然必须在树映射上显式同步（在本例中，似乎是序列化）。

何时使用迭代器的集合？

Answer 3

java。util。同时发生的ConcurrentSkipListMap是线程安全树映射的实现，它将保持自然的顺序

Map<String, String> treeMap = new ConcurrentSkipListMap<String, String>();

我们可以获得不可修改（只读）版本，如下所示：

TreeMap tM = new TreeMap();
Map tM2 = Collections.unmodifiableMap(tm1);

现在MaptM2是只读的。