¿Cómo detener un hilo esperando en una operación de bloqueo de lectura en Java?

Question

que tienen un hilo que se ejecuta el código siguiente:

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

donde in es System.in. ¿Cómo puedo detener dicho hilo con gracia? Ni cerrando System.in, ni usando Thread.interrupt parecen funcionar.

Answer 1

Esto es porque leer System.in (InputStream) es una operación de bloqueo.

mira aquí Is it possible to read from a InputStream with a timeout?

Answer 2

Se puede utilizar el método disponible() (que es no-bloqueo) para comprobar si hay algo para leer de antemano.

En 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

se puede utilizar un indicador externo para este

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

Si desea dar a un usuario un tiempo para introducir datos - tal vez para permitir anular valores predeterminados o interrumpir algún proceso automatizado -, luego espere primero y verifique la entrada disponible después de la pausa:

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

Te has encontrado con un niño de 9 años bug que nadie está dispuesto a arreglar. Dicen que hay algunas soluciones en this bug report. Lo más probable es que necesite encontrar otra forma de establecer el tiempo de espera (la espera ocupada parece inevitable).

Answer 6

que tenían el mismo problema hoy en día, y así es como me fijo, utilizando 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

¿Es seguro para cerrar en secuencia en otro hilo? Funciona para mí. En este caso, in.read(...) arroja la excepción SocketException.