Java发送消息线程

Question

我用 Java 编写了一个游戏，其中包含使用套接字和数据输入/输出流的客户端和服务器端。服务器端有时需要在“for”循环中向所有用户发送消息，但由于写入套接字可能会阻塞，因此我为每个向他发送消息的用户创建了一个线程（以及为每个监听的用户创建了另一个线程）传入消息）。发送线程是基于这个想法构建的：

private ArrayList<Object> messages = new ArrayList<Object>(),
                          newMessages = new ArrayList<Object>();

public void run() {
    while (true) {
        for (Object message: messages) {
            try {
                if (message instanceof Byte)
                    out.writeByte((Byte)message);
                else if (message instanceof Boolean)
                    out.writeBoolean((Boolean)message);
                else if (message instanceof String)
                    out.writeUTF((String)message);
                else if (message instanceof Integer)
                    out.writeInt((Integer)message);
                else if (message instanceof Long)
                    out.writeLong((Long)message);
            } catch (IOException e) {}
        }
        synchronized (newMessages) {
            messages.clear();
            messages.addAll(newMessages);
            newMessages.clear();
        }
    }
}

public void write(Object message) {
    synchronized (newMessages) {
        newMessages.add(message);
    }
}

不幸的是 run() 方法不断运行，所以我想插入一个 sleep 命令，以实现如下所示的效果：

private ArrayList<Object> messages = new ArrayList<Object>(),
                          newMessages = new ArrayList<Object>();

public void run() {
    while (true) {
        try {
            if (messages.isEmpty() && newMessages.isEmpty())
                sleep(0);
        } catch (InterruptedException e) {}
        for (Object message: messages) {
            try {
                if (message instanceof Byte)
                    out.writeByte((Byte)message);
                else if (message instanceof Boolean)
                    out.writeBoolean((Boolean)message);
                else if (message instanceof String)
                    out.writeUTF((String)message);
                else if (message instanceof Integer)
                    out.writeInt((Integer)message);
                else if (message instanceof Long)
                    out.writeLong((Long)message);
            } catch (IOException e) {}
        }
        synchronized (newMessages) {
            messages.clear();
            messages.addAll(newMessages);
            newMessages.clear();
        }
    }
}

public void write(Object message) {
    synchronized (newMessages) {
        newMessages.add(message);
        interrupt();
    }
}

但这可能会导致线程在有消息要发送时进入睡眠状态，例如，在 run() 方法进行 isEmpty() 检查后调用 write() 方法，该方法返回 true，但尚未启动睡觉。我真的想不出一种方法来避免 sleep(0) 这个问题，有人有想法吗？或者我在这方面走错了路？

非常感谢。

Answer 1

看看LinkedBlockingQueues。您可以在代码中使用其中的一个来代替messages和对象。newMessages

此类允许您从一个线程 A 添加项目并从另一个线程 B 读取项目。线程 B 将等待，直到线程 A 添加新消息。应该正是您所需要的。