如何使用BufferedReader（Java）中断读取操作？

Question

虽然我读了很多其他答案，但我不明白如何在不发送输入的情况下关闭BufferedReader。这是我计划的阻隔部“）endListening（”从主线程

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; 
    } 
} 

当我打电话，程序终止 - 而不是之前用户输入任何东西。我想程序立即终止 - 如何intterupt这个BufferdReader（创建像BufferedReader（new InputStreamReader（System.in）））？

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

Answer 1

你可以检查一下if there's data available调用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;