清理线程池的问题

Question

我有一个多线程的 Java 服务器，我已经为它创建了一个线程池。 现在一切顺利，我的服务器接受并从连接到它的客户端读取数据，但我真的不知道如何在连接关闭后清理套接字。

这是我的代码：

public static void main(String[] args) throws Exception {
    // TODO Auto-generated method stub

    ThreadPooledServer server = new ThreadPooledServer(queue,7001);
    new Thread(server).start();
}

ThreadPooledServer 类：

public class ThreadPooledServer implements Runnable {
    protected ExecutorService threadPool = Executors.newFixedThreadPool(5);

public ThreadPooledServer(BlockingQueue queue,int port) {
    this.serverPort = port;
    this.queue=queue;
}

    public void run() {
        openServerSocket();

        while (!isStopped()) {
            Socket clientSocket = null;
            try {
                clientSocket = serverSocket.accept();
                clientconnection++;
            } catch (IOException e) {
                if (isStopped()) {
                    System.out.println("Server Stopped.");
        return;
            }

            throw new RuntimeException("Error accepting client connection", e);
        }

        WorkerRunnable workerRunnable = new WorkerRunnable(queue,clientSocket);

        this.threadPool.execute(workerRunnable);

    }
    this.threadPool.shutdown();

    System.out.println("Server Stopped.");
}

private synchronized boolean isStopped() {
    return this.isStopped;
}

public synchronized void stop() {
    this.isStopped = true;

    try {
        this.serverSocket.close();
    }

    catch (IOException e) {
        throw new RuntimeException("Error closing server", e);
    }
}

以下是我不明白的地方：我的 while() 循环接受客户端的工作时间与 isStopped 一样长。

当 isStopped 设置为 true 时，我的循环结束，然后我关闭了我的线程池，这是正确的。

isStopped 在 onstop(){.......}....中设置为 true。

我应该在哪里调用 onstop()...？

因为此时我没有使用这个方法，所以我没有调用它，这意味着我没有正确清理我的线程。

WorkerRunnable 类：

    public class WorkerRunnable implements Runnable {
        public WorkerRunnable(BlockingQueue queue2, Socket clientSocket2) {
        // TODO Auto-generated constructor stub

            this.clientSocket2 = clientSocket2;

            this.queue2 = queue2;
        }

        public void run() {
            try {
                is = new ObjectInputStream(this.clientSocket2.getInputStream());

                try {
                    while (!stop) {
                        System.out.println("Suntem in interiorul buclei while:!");

                        v = (Coordinate) is.readObject();

                        queue2.put(v);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    is.close();

                    clientSocket2.close();
                }

                is.close();
                clientSocket2.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        public void stop() {
            this.stop = true;
        }
    }
}

在这里我有同样的问题。我应该如何正确清理和关闭我的套接字？

Answer 1

一旦您调用shutdown()，线程池将在所有任务完成后关闭每个线程。

您应该从任何知道池应该关闭的代码中调用onstop()。这取决于您的应用程序的其余部分做什么，以及您为什么要在应用程序完成之前停止池。