Java线程池内存泄漏

Question

我正在尝试构建一个服务器，但线程池的使用引入了内存泄漏，导致我的堆溢出。

我的服务器从主线程创建两个主线程:接受器和消费者。我是 JProfiler 的新手，但它似乎非常清楚地指出我下面的代码(Acceptor)是罪魁祸首。

Acceptor 线程接受来自客户端的新连接。接受调用后，线程池中的新线程将用于处理连接。

public class AcceptorThread implements Runnable{
LinkedBlockingQueue<LinkedList<Log_Message>> queue = null;
public AcceptorThread(LinkedBlockingQueue<LinkedList<Log_Message>> queue){
    this.queue = queue;
}

@Override
public void run() {
    ExecutorService acceptors = Executors.newCachedThreadPool();
    ServerSocket socket = null;
    try {
        socket = new ServerSocket(44431);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    while(!init_LogServer.isStopped()){
        Socket connectionSocket = null;
        try {
            connectionSocket = socket.accept();
        } catch (IOException e) {
            e.printStackTrace();
        }
        init_LogServer.addList();
        System.out.println("Accepted New List: " + init_LogServer.getListCount());
        Runnable worker = new List_Acceptor(connectionSocket, queue);
        acceptors.execute(worker);
    }
}

}

新线程从线程池中接收一个对象链表，该链表被添加到队列中，线程完成。我的理解是，在完成下面的代码后，线程将终止，下面的对象将被 GC 收集，并且线程将重新进入线程池以供重用。我看不到任何明显的小内存泄漏，所以我猜测发生的情况是下面的类从未被 GC 收集，从而导致堆构建，这是正确的吗？将接收到的列表添加到队列后，如何销毁以下对象？

public class List_Acceptor implements Runnable{
Socket socket = null;
private LinkedList<Log_Message> lmList = null;
private LinkedBlockingQueue<LinkedList<Log_Message>> queue = null;
private String dumpMessage = null;

public List_Acceptor(Socket socket, LinkedBlockingQueue<LinkedList<Log_Message>> queue){
    this.queue = queue;
    this.socket = socket;
}

@Override
public void run() {
    ObjectInputStream input = null;
    try {
        input = new ObjectInputStream(socket.getInputStream());
    } catch (IOException e3) {
        // TODO Auto-generated catch block
        e3.printStackTrace();
    }
    Object received = null;
    try {
        received = input.readObject();
    } catch (ClassNotFoundException | IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    try {
        lmList = (LinkedList<Log_Message>) received;
    } catch (Exception e1) {
        //e1.printStackTrace();
        System.out.println("Received DumpLog");
        dumpMessage = (String) received;
        System.out.println("Dump: "+dumpMessage);
        init_LogServer.stop();
        e1.printStackTrace();
    }

    //close socket
    try {
        socket.close();
        input.close();
    } catch (IOException e2) {e2.printStackTrace();}

    try {
        queue.put(lmList);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

}

}

编辑:我了解到，显然当一个对象/类通过线程实例化时，就像我对线程池所做的那样，GC 被限制清理该对象。这似乎是内存泄漏的可能原因，也可能是我的问题。考虑到这一点，明天我将重新设计，以便 AcceptorTread 执行必要的步骤将接收到的列表放入队列中，它应该更慢，但会防止堆问题。那有意义吗？

Answer 1

关于您上次的编辑:当前线程不会使您创建的所有 List_Acceptor 对象保持 Activity 状态(顺便说一句，Java 命名约定是 ListAcceptor)。

JProfiler 中的分配热点 View 只是告诉您仍在堆上的对象是否已分配。这并不意味着这些对象不能被GC。

要分析哪些对象实际上被强引用，请转到 JProfiler 中的“堆遍历器”。然后选择所有 List_Acceptor 对象并转到“传入引用” View 。对于单个对象，单击“显示 GC 根目录的路径”。然后您将看到一系列引用，防止对象被 GC 处理。

通过“累积传入引用” View ，您可以检查所有 List_Acceptor 对象是否都是这种情况。