如何同步两种方法

Question

我有以下 Java 聊天服务器应用程序代码 -

public synchronized List<ChatMessage> getMessages(int messageNumber) {
    return messages.subList(messageNumber + 1, messages.size());
}

public synchronized int addMessage(ChatMessage c) {
    messages.add(c);
    return messages.size()-1;
}

我有以下测试代码 -

public static void main(String[] args) {
    final ChatRoom c = new ChatRoom();
    Thread user1 = new Thread(new Runnable() {
        public void run() {
            for(int i=0;i<1000;i++) {
                c.addMessage(new ChatMessage());
                c.getMessages(0);
            }
        }
    });
    Thread user2 = new Thread(new Runnable() {
        public void run() {
            for(int i=0;i<1000;i++) {
                c.addMessage(new ChatMessage());
                c.getMessages(0).size();
            }
        }
    });
    user1.start();
    user2.start();
}

我收到 ConcurrentModificationException。

这怎么可能？

Answer 1

这怎么可能？

您的getMessages 方法只是在原始列表中返回一个视图。它不会创建列表的副本。因此，一个线程正在使用列表上的视图，而另一个线程正在修改列表 - 此时，您会遇到异常。

来自List.subList 的文档：

如果后备列表（即此列表）以除通过返回列表之外的任何方式进行结构修改，则此方法返回的列表的语义将变为未定义。 （结构性修改是改变这个列表的大小，或者以其他方式扰乱它，使得正在进行的迭代可能产生不正确的结果。）

不清楚你在这里真正想要实现什么，但基本上你不能使用subList 神奇地创建一个线程安全列表:)

Answer 2

最简单的做法是创建一个组合方法

public synchronized int addMessageAndGetCount(ChatMessage c) {
    messages.add(c);
    return messages.size();
}

public static void main(String... args) {
    final ChatRoom c = new ChatRoom();
    final Runnable runner = new Runnable() {
        public void run() {
            for(int i = 0; i < 1000; i++) {
                c.addMessageAndGetCount(new ChatMessage());
            }
        }
    };
    new Thread(runner).start();
    new Thread(runner).start();
}

您不能安全地从同步块返回列表或子列表。您可以退还一份副本，但您只需要大小即可。