我有一个使用网络端口进行通信的线程。我添加了 cancel() 方法来停止执行并关闭网络资源(如何正确停止 Java 中的线程?)
private class ServerThread extends Thread {
int portNumber;
String serverAddress = null;
public ServerThread(String serverAddress, int portNumber) {
super();
this.serverAddress = "localhost";
this.portNumber = portNumber;
}
@Override
public void run() {
ServerSocket listener;
Socket socket;
try {
listener = new ServerSocket(this.portNumber);
socket = listener.accept();
BufferedReader in = new BufferedReader(new InputStreamReader(
socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(),
true);
while (!isInterrupted()) {
String input = in.readLine();
if (input != null) {
out.println(input);
System.out.println("Hi:" + input);
}
} // end of while loop
System.out.println("OUT"); <-- ???
socket.close(); <-- ???
listener.close(); <-- ???
} catch (IOException e) {
e.printStackTrace();
}
}
public void cancel() {
System.out.println("cancel called");
interrupt();
}
}
问题是,当我执行 ServerThread 并发送 cancel() 消息以完成执行时,这三行代码似乎从未执行过:System.out.println("OUT"); socket.close(); listener.close();
.
似乎我不需要发送 cancel() 消息来完成线程。
ServerThread s = new ServerThread(serverAddress, serverPortNumber);
s.start();
...
s.cancel(); // ???
关闭线程使用的资源的推荐方法是什么?当不再使用线程时,我不必关闭资源吗?还是一切都只是自动处理?
添加
似乎该线程会自动终止,因为此代码可以正常工作。
while(true) {
String input = in.readLine();
if (input != null) {
System.out.println("Received:" + input);
out.println(input);
}
} // end of while loop
/* System.out.println("OUT");
socket.close();
listener.close(); */