停止ServerSocket accept（）循环线程
我正在实现一个非常基本的API，以更好地控制ServerSocket和套接字，但是由于我缺乏线程知识，所以我无法解决一个非常奇怪的问题。让我解释一下。
在我的类SocketStreamReceiver中，我使用辅助线程来监听带有“ 0”的新套接字。客户端可以使用2种方法：start（）和stop（），我的SocketStreamReceiver可以用来启动（创建线程并以
accept()
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;
}
}
没有找到相关结果
已邀请:
1 个回复
痰嫉
public void stop() { running = false; try{ if (server != null) server.close (); } catch (IOException ignored){ } }