如何使用 BufferedReader (Java) 中断读取操作

Question

您好，尽管我阅读了很多其他答案，但不明白如何在不发送输入的情况下关闭BufferedReader。这是我程序的阻塞部分：

public class AuctionClientUserListener extends Thread {
    private PrintWriter out;
    private BufferedReader stdIn;
    private int udpPort;
    private boolean running = true;
    private boolean listening = true;
    // needs server connection out
    public AuctionClientUserListener(BufferedReader stdIn,PrintWriter out,int udpPort) {
        this.stdIn = stdIn;
        this.out = out;
    }
    public void run() {
        String fromUser;
        while(true) {
            if(!listening) {
                break;
            }
            try {
                fromUser = stdIn.readLine(); // BLOCKS
                if (fromUser != null) {
                        System.out.println("Me: " + fromUser);
                        // check if to send udp port
                        String[] spinput = fromUser.split(" ");
                        if(spinput[0].equals("!login")) {
                            fromUser+=" "+udpPort;
                        }
                        out.println(fromUser);
                        if(fromUser.equals("!end")) {
                            listening = false;
                        }
                }
            } catch(Exception e) {
                listening = false;
            }
        }
        running = false;
    }
    public boolean running() {
        return running;
    }
    public void endListening() {
        this.listening =  false;
    }
}

当我从主线程调用"endListening（）"时，程序终止 - 但不是在用户输入任何内容之前。我想让程序立即终止 - 如何启动这个缓冲阅读器（像缓冲阅读器（新的输入流阅读器（System.in））一样创建）？

我试图在主线程中的这个线程上调用 stdIn.close（） 和 thread.interrupt（），但它不起作用。我还尝试关闭主线程中的 InputStreamReader。

Answer 1

您可以在调用 BufferedReader.readLine() 之前检查是否有可用的数据，即

while(true) {
    if (!listening) break;
    if (System.in.available() > 0) {
        try {
            fromUser = stdIn.readLine();
            // etc.

Answer 2

必须使用 thread.interrupt 向线程发出信号以中断其进程。准备好捕捉线程启动的InterruptedException。

http://docs.oracle.com/javase/tutorial/essential/concurrency/interrupt.html

Answer 3

我认为您可以使用 stdIn.close（） 关闭您的 BufferedReader;