停止 ServerSocket Accept() 循环线程

Question

我正在实现一个非常基本的 API，以便更好地控制 ServerSocket 和 Sockets，但我遇到了一个非常奇怪的问题，由于缺乏线程知识，我无法修复该问题。让我解释一下。

在我的 SocketStreamReceiver 类中，我使用辅助线程通过 ServerSocket#accept() 来侦听新套接字。有 2 个方法：start() 和 stop()，客户端可以使用它们来启动（创建线程并开始使用 accept() 进行侦听）和停止（关闭 ServerSocket 并销毁线程） SocketStreamReceiver。

如何实现 stop() 方法？请记住，stop() 可以在 doSomething() 内部调用，在 start() 启动的同一个辅助线程中。您可以更改任何您想要的内容：如果需要，您可以在线程内创建 ServerSocket，就在 while(running) 之前。

public class SocketStreamReceiver{
    ...
    private Thread thread;
    private ServerSocket server;
    private boolean running;
    ...

    public void start () throws IOException{
        if (thread != null) return;

        server = new ServerSocket (port);
        thread = new Thread (new Runnable (){
            @Override
            public void run (){
                try{
                    while (running){
                        Socket socket = server.accept ();
                        doSomething (socket);
                    }
                }catch (SocketException e){
                    ...
                }catch (IOException e){
                    ...
                }
            }
        }, "SocketStreamReceiver");
        thread.start ();
    }

    public void stop () throws IOException{
        if (thread == null) return;

        //code...

        thread = null;
    }
}

谢谢。

编辑 - 解决方案：

public class SocketStreamReceiver{
    private Thread thread;
    private ServerSocket server;
    private volatile boolean running;
    ...

    public synchronized void start () throws IOException{
        if (thread != null) throw new IllegalStateException ("The receiver is already started.");

        server = new ServerSocket (port);
        thread = new Thread (new Runnable (){
            @Override
            public void run (){
                try{
                    running = true;
                    while (running){
                        doSomething (server.accept ());
                        ...
                    }
                }catch (SocketException e){
                    ...
                }catch (IOException e){
                    ...
                }
            }
        }, "SocketStreamReceiver");
        thread.start ();
    }

    public synchronized void stop (){
        if (thread == null) return;

        running = false;
        try{
            if (server != null){
                server.close ();
            }
        }catch (IOException e){}

        thread = null;
    }
}

Answer 1

我会这样做

public void stop() {
    running = false;
    try{
        if (server != null) server.close ();
    } catch (IOException ignored){
    }
}

似乎你甚至不需要运行标志。不过，我会在您的服务器接受代码中使用它来确定是否需要异常。即当运行 == false 时忽略所有异常。

我会让 running 变得不稳定。

如果您可以从不同的线程运行它们，我将使 start()/stop() 同步。