Làm thế nào để dừng một chuỗi đang chờ trong một hoạt động đọc chặn trong Java?

Question

Tôi có một thread thực thi đoạn mã sau:

public void run() { 
    try { 
     int n = 0; 
     byte[] buffer = new byte[4096]; 
     while ((n = in.read(buffer)) != -1) { 
      out.write(buffer, 0, n); 
      out.flush(); 
     } 
    } catch (IOException e) { 
     System.out.println(e); 
    } 
} 

nơi in là System.in. Làm thế nào tôi có thể ngăn chặn chủ đề như vậy một cách duyên dáng? Không đóng System.in cũng như không sử dụng Thread.interrupt có vẻ như hoạt động.

Answer 1

Điều này là do đọc System.in (InputStream) là một hoạt động chặn.

Look đây Is it possible to read from a InputStream with a timeout?

Answer 2

Bạn có thể sử dụng phương pháp có sẵn() (đó là non-blocking) để kiểm tra xem có bất cứ điều gì để đọc trước.

Trong pseudo-java:

//... 
while(running) 
{ 
    if(in.available() > 0) 
    { 
     n = in.read(buffer); 
     //do stuff with the buffer 
    } 
    else 
    { 
     Thread.sleep(500); 
    } 
} 
//when running set to false exit gracefully here... 

Answer 3

bạn có thể sử dụng một lá cờ bên ngoài cho điều này

boolean flag = true; 


public void run() { 
    try { 
     int n = 0; 
     byte[] buffer = new byte[4096]; 
     while ((n = in.read(buffer)) != -1 && flag) { 
      out.write(buffer, 0, n); 
      out.flush(); 
     } 
    } catch (IOException e) { 
     System.out.println(e); 
    } 
} 

Answer 4

Nếu bạn muốn cung cấp cho người dùng một thời gian để nhập dữ liệu - có thể cho phép trọng giá trị mặc định hoặc gián đoạn một số quy trình tự động -, sau đó đợi trước và kiểm tra đầu vào có sẵn sau khi tạm dừng:

System.out.println("Enter value+ENTER within 5 Seconds to override default value: "); 
try{ 
    Thread.sleep(5000); 
} catch {InterruptedException e){} 

try{ 
    int bytes = System.in.available(); 
    if (bytes > 0) { 
    System.out.println("Using user entered data ("+size+" bytes)"); 
    } else { 
    System.out.println("Using default value"); 
    } 
} catch(IOException e) { /*handle*/ } 

Answer 5

Bạn đã tình cờ gặp một người 9 tuổi bug không ai sẵn sàng sửa chữa. Họ nói rằng có một số cách giải quyết trong this bug report. Hầu hết có thể, bạn sẽ cần phải tìm một số cách khác để thiết lập thời gian chờ (chờ đợi bận rộn dường như không thể tránh khỏi).

Answer 6

tôi đã cùng một vấn đề ngày hôm nay, và đây là cách tôi cố định nó, sử dụng in.ready():

public void run() { 
    String line; 
    // Some code 

    while(!Thread.currentThread().isInterrupted()){ 
     try { 
      if (in.ready()) { 
       line = in.readLine(); 
      } 
     } catch (Exception e) { 
      try { 
       Thread.currentThread().wait(500); 
      } catch (InterruptedException e1) { 
       // Do what we want when thread is interrupted 
      } 
     } 
    } 
} 

Answer 7

Có an toàn để đóng trong dòng trong chủ đề khác? Nó phù hợp với tôi. Trong trường hợp này, in.read(...) ném ngoại lệ SocketException.