中断正在等待来自套接字的 IO 的线程？

发布于 2024-12-26 04:14:32 字数 1012 浏览 4 评论 0原文

我有一个应用程序可以侦听指定主机名和端口上的传入连接。使用 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，但是可以用 来完成吗？中断（）或其他什么？）

原文

I have an app that listens to incoming connections on a specified hostname and port. The listening is invoked with the method listen() (see below), which waits constantly for an incoming connection using ServerSocket.accept(), creating a new Thread to handle the input stream.

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

Now I want to stop the running of listenerThread. But when I call this.listenerThread.interrupt(), this doesn't work.
I thought you can stop a thread by interrupting it, so why isn't that working?

(Notice: A possible solution is to close the ServerSocket using this.serverSocket.close(), but can it be accomplished with interrupt() or something?)

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

只想待在家 2025-01-02 04:14:32

调用serverSocket.close()，

我猜因为你还没有进行IO - 你不能中断它，并且由于accept()不会抛出InterruptedException，你就赢了无法打断它。线程被中断，但是您必须自己检查该标志Thread.isInterrupted()。

请参阅如何中断 ServerSocket Accept() 方法？。

回复收藏 0 原文

晨曦慕雪 2025-01-02 04:14:32

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

回复收藏 0 原文

寄居者 2025-01-02 04:14:32

使用这个：

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() 方法。

Use this:

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) { }
        }
    }
}

and from the listen() method just call setStop() method of the thread.

回复收藏 0 原文

~没有更多了~