Java中的多线程死锁

Question

我正在用 Java 为游戏编写一个机器人。一个线程管理 Manager 和 Worker 线程的时间并为它们发送心跳。 Manager 收集并解释来自服务器的消息，Worker 线程从 Manager 接收命令（在类中带有详细信息）并根据这些信息进行操作。

现在，我遇到了多线程死锁问题，我不确定是否有替代方案。

以下是我的管理器类中的一些方法： 当用户单击按钮时，我从 GUI 线程调用 getMessageFromUsername。从另一个线程调用以下方法。

private ArrayList<Message> MessageList = new ArrayList<>();

public synchronized Message getMessageFromUsername(String username) {        
        for( Message msg : MessageList ) {
            if( msg.username.equalsIgnoreCase(username) ) {
                Message m = new Message(msg.num, msg.username, msg.id);                
                return m;
            }
        }

        return null;
    }

我的管理器线程从套接字读取信息，并在一个连续循环中将信息添加到 MessageList。 （另一个，即）

private synchronized void parseMessage() {}
private void main() { while(1) { parseMessage(/*Adds message to MessageList*/); Sleep(); } }

现在，我的问题是一个非常菜鸟的问题——因为如果我想写入 MessageList，我必须使用同步来访问它。但是，由于这发生在循环中并且消息不断通过套接字进入，因此会导致死锁，因为它会一直锁定我的对象，并且这会在循环中发生。

我可以做些什么来解决我的死锁问题？

Answer 1

我认为您应该使用 ArrayBlockingQueue 并避免使用循环，而是使用 poll/take/put/offer 等阻塞方法替换循环。

基于数组的集合表现更好，因此您应该首先考虑这些，然后是基于链接节点的集合。所以 ArrayBlockingQueue 比 ConcurrentLinkedQueue 要好。

Answer 2

正如我在评论中所说，你没有死锁，但你的线程饿死了。

你有两个选择：

• 要么选择一些具有优先顺序的线程

• 或者您选择启用并发的集合。 java.util.concurrent 有很多此类集合的示例。但请注意 - 修改一个 foreached 的集合绝不是一个好主意。也许你只需要一种先进先出队列？一个线程添加消息，另一个线程弹出并评估？

例如有ConcurrentLinkedQueue，它提供Add 方法（供您的parseMessage 使用）和isEmpty()（用于您其他线程的while 循环）。

虽然我不是 Java 专家，但我会告诉你这个答案：How to use ConcurrentLinkedQueue? 它提供了一些实用的建议。

Answer 3

如果我正确理解了您的用例，那么我相信我会考虑为您的消息列表使用 BlockingQueue 的实现。正如已经提到的，还提供了并发实现，因此您不需要外部同步。您应该可以从队列中简单地poll() 或take()。

Answer 4

我认为主要问题是您似乎在等待消息到达时一直保持锁定。

当您开始阅读消息时，您通过parseMessage() 锁定- 可能有一段时间不会到达，并且其他线程在消息实际到达之前没有机会做任何事情。然后它可能会错过它的机会......（等待/通知可能会解决问题的后半部分，但我认为这里不需要它）。

我将重组如下：

 // just parse and return the message, don't add it to the list
 private Message parseMessage() {} 

 private void main() {
    while(1) {
       Message msg = parseMessage();
       synchronized(messageList) {
         messageList.add(msg);
       }
    } 
 }