中断阻塞等待来自套接字的IO的线程？

Question

我有一个应用程序可以侦听指定主机名和端口上的传入连接。使用listen()（见下文）方法调用监听，该方法不断等待使用ServerSocket.accept() 的传入连接，创建一个新的Thread 来处理输入流。

private ServerSocket serverSocket;
private Thread listenerThread;

public void listen() throws IOException {
    this.listenerThread = new Thread(new Runnable() {

        @Override
        public void run() {
            while (true) {
                try {
                    Socket socket = TheServerClass.this.serverSocket.accept();
                    // Create new thread to handle the incoming connection
                }
                catch (IOException exc) { }
            }
        }
    });
    this.listenerThread.start();
}

现在我想停止运行listenerThread。但是当我打电话给this.listenerThread.interrupt() 时，这不起作用。
我以为你可以通过中断线程来停止它，那为什么不起作用呢？

（注意：一种可能的解决方案是使用this.serverSocket.close() 关闭ServerSocket，但可以使用interrupt() 或其他方式来完成吗？）

Answer 1

致电serverSocket.close()，

我猜因为你还没有做 IO - 你不能中断它，因为accept() 没有抛出 InterruptedException 你将无法中断它。线程被中断了，但是你必须自己检查那个标志Thread.isInterrupted()。

见How can I interrupt a ServerSocket accept() method?。

Answer 2

答案就在问题中。您需要关闭套接字。使用serverSocket.close() 完成。 Thread.interrupt() 不关心套接字。

Answer 3

使用这个：

public class MyThread extends Thread {

    private boolean stop;
    private ServerSocket serverSocket;

    public MyThread(ServerSocket ss) {
        this.serverSocket = ss;
        this.stop = false;
    }

    public void setStop() {
        this.stop = true;
        if (this.ss != null) {
            this.ss.close();
        }
    }

    public void run() {
        while (!stop) {
            try {
                Socket socket = serverSocket.accept();
                // Create new thread to handle the incoming connection 
            }
            catch (IOException exc) { }
        }
    }
}

从listen() 方法调用线程的setStop() 方法。