我正在尝试终止子线程,该线程正在等待来自服务器的输入。我已经尝试使用标志来实现,但它停在了
message = serverReader.readLine() && !isClosed()
,
因为它在等待来自服务器的输入,只有在此输入后才检查标志并中断。但这不是一个好的解决方案,因为我无法在没有服务器消息的情况下停止它。
我还尝试首先检查标志,然后再读取行,但也不起作用。
是否有任何好的解决方案?
@Override
public void run() {
String message;
try {
while((message = serverReader.readLine()) != null && !isClosed()) {
consoleWriter.println("Other user: " + message);
consoleWriter.flush();
}
} catch (Exception e) {
e.printStackTrace();
}
}
private void setUpNetworking() {
try {
Socket socket = new Socket("127.0.0.1", 5000);
InputStreamReader streamReader = new InputStreamReader(socket.getInputStream());
serverWriter = new PrintWriter(socket.getOutputStream());
serverReader = new BufferedReader(streamReader);
//Starting listening messages from server
incomeReader = new Thread(new IncomeMessagesReader(serverReader, consoleWriter, this));
incomeReader.start();
System.out.println("Networking established");
} catch (IOException e) {
e.printStackTrace();
}
}