停止等待很长时间的线程

Question

我在终止等待accept() 调用的线程时遇到问题。

accept()：侦听与此套接字建立的连接并接受它。该方法会一直阻塞，直到建立连接。

我有实现Runnable 接口的GestorBuzon：

public class GestorBuzon implements Runnable{

   private static volatile boolean running = true;

   public void run() {
       try {
           while (running) {
               -- pre code
               accept();
               -- post code
           }
       } catch(IOException e) {
             terminate();
       } 
   }

   public static void terminate() {
       running = false;
   }
}

我有 MessageSystem 类来启动和停止线程：

public class MessageSystem {

    private GestorBuzon gestorBuzon;
    private Thread thread;

    public MessageSystem() {
        // Starts the Thread
        contextInitialized();
    }

    private void contextInitialized() {
        gestorBuzon = new GestorBuzon();
        thread = new Thread(gestorBuzon);
        thread.start();
    }

    private void contextDestroyed() {
        if (thread != null) {
            gestorBuzon.terminate();
            try {
                thread.join();
            } catch (InterruptedException e) {
                gestorBuzon.terminate();
            }
        }
    }    
} 

我在Runnable 类中多次调用accept() 函数，但是当我使用contextDestroyed() 函数时，线程仍在等待accept() 并且线程不会终止。我做错了什么？

它必须这样做：

Answer 1

只需通过setSoTimeout() 在ServerSocket 上设置套接字超时，并在它触发时捕获SocketTimeoutException。然后，您可以检查 catch 块等中的 running 标志，并决定是继续接受还是停止接受。