如何从容器中删除死线程

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);

Answer 2

您可以使用

Timer

来安排定期

TimerTask

，它将遍历列表并删除死线程。这是草图：

static final List<Thread> threads = new LinkedList<Thread>();
static final Timer timer = new Timer(true);
public static void main(String[] args) {
  timer.scheduleAtFixedRate(new TimerTask() {public void run() {
    for (Iterator<Thread> it = threads.iterator(); it.hasNext();)
      if (!it.next().isAlive()) it.remove();
  }}, 0, 10000);
}