我正在开发一个基于线程的异步套接字客户端。当程序调用readLine()
时,它会无限期地阻塞并且永远不会返回。
public class ADNClient {
Socket socket = null;
DataOutputStream dataOutputStream = null;
DataInputStream dataInputStream = null;
Thread listener = new Thread(new Runnable() {
@Override
public void run() {
String line;
try {
// Stop here and doesn't progress
while ((line = dataInputStream.readLine()) != null) {
//DO something
}
}
catch (IOException e) {}
});
public ADNClient() {
try {
socket = new Socket("192.168.1.5", 5000);
dataOutputStream = new DataOutputStream(socket.getOutputStream());
dataInputStream = new DataInputStream(socket.getInputStream());
listener.start();
//sender.start();
} catch (Exception e) {
Log.e("ADN", e.getMessage());
}
}
public void close() {
listener.stop();
try {
socket.close();
} catch (IOException e) {
Log.e("ADN", e.getMessage());
}
}
}