java - 如何从容器中删除死线程

Question

我将线程存储在容器中。随着时间的推移，其中一些线程将运行，而其中一些将死亡。我想要实现的是:自动(或定期)从容器中删除死(停止)线程。最好的方法是什么？

编辑:我将我的线程存储在一个简单的链接列表中:

LinkedList<ServerThread> threadPool = new LinkedList<ServerThread>();

这个容器必须是动态的，因为随着时间的推移，我必须添加(显然是删除)线程。

EDIT2:这就是我目前管理线程的方式。正如你所看到的，我等待传入的连接，我不知道它什么时候到达，但是当它到达时，我必须在新线程中处理它。

while (!interrupted()) {
            try {
                Socket clientSocket = serverSocket.accept();
                if (portNumber == Server.SMTP_PORT_NUMBER) {
                    threadPool.add(new SMTPThread(clientSocket, db));
                    threadPool.getLast().setName("SMTP Thread " + ++threadCounter);
                } else {
                    threadPool.add(new POP3Thread(clientSocket, db));
                    threadPool.getLast().setName("POP3 Thread " + ++threadCounter);
                }

                threadPool.get(threadPool.size() - 1).start();

            } catch (SocketTimeoutException e) {
            } catch (IOException ioe) {
            }
        }

Answer 1

除非有特定原因，否则您不应维护自己的线程列表。我建议使用自 Java 5 以来可用的优秀 ExcecutorService 类。如下所示:

// create a thread pool with 10 workers
ExecutorService threadPool = Executors.newFixedThreadPool(10);
// or you can create an open-ended thread pool
// ExecutorService threadPool = Executors.newCachedThreadPool();
for (Job job : jobsToDo) {
    threadPool.submit(new MyJobProcessor(job));
}
// once we have submitted all jobs to the thread pool, it should be shutdown
threadPool.shutdown();
...
public class MyJobProcessor implements Runnable {
    private Job job;
    public MyJobProcessor(Job job) {
        this.job = job;
    }
    public void run() {
        // process the job
    }
}

线程池将负责维护池中正在运行的线程。这些线程将在下一个作业中重新使用，并且当池中不再有作业且已关闭时，线程将被关闭。您不需要自己收集任何死线程。

<小时/>

编辑:

就您发布的代码而言，要从池中删除已完成的线程，您应该像这样运行它们:

 Iterator<ServerThread> iterator = threadPool.iterator();
 while (iterator.hasNext()) {
     ServerThread thread = iterator.next();
     if (!thread.isAlive()) {
        // remove it from the linked list
        iterator.remove();
     }
 }

每次向池中添加新线程时，我都会在之后执行此操作。另外，请记住 LinkedList 执行 get(#) 方法调用的效率不高。我建议您调整代码以执行以下操作:

            Socket clientSocket = serverSocket.accept();
            ServerThread serverThread;
            if (portNumber == Server.SMTP_PORT_NUMBER) {
                serverThread = new SMTPThread(clientSocket, db);
                serverThread.setName("SMTP Thread " + ++threadCounter);
            } else {
                serverThread = new POP3Thread(clientSocket, db);
                serverThread.setName("POP3 Thread " + ++threadCounter);
            }
            serverThread.start();
            threadPool.put(serverThread);