我正在使用多线程环境,一个Thread通过反复调用scanner.nextLine()来不断监听用户输入.
要结束应用程序,此runloop由另一个线程停止,但是在最后一次用户输入之前,监听线程不会停止(由于nextLine()的阻塞性质).
要结束应用程序,此runloop由另一个线程停止,但是在最后一次用户输入之前,监听线程不会停止(由于nextLine()的阻塞性质).
关闭流似乎不是一个选项,因为我从System.in读取,它返回一个不可关闭的InputStream.
有没有办法打断扫描仪的阻塞,以便它会返回？
谢谢
解决方法
该
article描述了一种在阅读时避免阻塞的方法.它给出了代码片段,您可以根据我在评论中指出的内容进行修改.
import java.io.*;
import java.util.concurrent.Callable;
public class ConsoleInputReadTask implements Callable<String> {
public String call() throws IOException {
BufferedReader br = new BufferedReader(
new InputStreamReader(System.in));
System.out.println("ConsoleInputReadTask run() called.");
String input;
do {
System.out.println("Please type something: ");
try {
// wait until we have data to complete a readLine()
while (!br.ready() /* ADD SHUTDOWN CHECK HERE */) {
Thread.sleep(200);
}
input = br.readLine();
} catch (InterruptedException e) {
System.out.println("ConsoleInputReadTask() cancelled");
return null;
}
} while ("".equals(input));
System.out.println("Thank You for providing input!");
return input;
}
}
