Как остановить поток, ожидающий операции блокировки чтения в Java?

У меня есть поток, который выполняет следующий код:

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

где in - System.in. Как я могу прекратить такую тему изящно? Ни закрытие System.in, ни использование Thread.interrupt не работают.

Ответы

Ответ 1

Это потому, что чтение System.in(InputStream) - это операция блокировки.

Посмотрите здесь Можно ли читать из InputStream с таймаутом?

Ответ 2

Вы наткнулись на 9-летнюю bug, которую никто не хочет исправлять. Говорят, что в этот отчет об ошибках есть некоторые обходные пути. Скорее всего, вам нужно будет найти другой способ установки таймаута (ожидание ожидания кажется неизбежным).

Ответ 3

Вы можете использовать метод available() (который не блокирует), чтобы проверить, есть ли что-нибудь, что нужно прочитать заранее.

В псевдо-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...

Ответ 4

У меня была такая же проблема сегодня, и именно так я ее исправил, используя 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
            }
        }
    }
}

Ответ 5

Безопасно ли закрывать поток в другом потоке? Меня устраивает. В этом случае in.read(...) генерирует исключение SocketException.

Ответ 6

Если вы хотите дать пользователю некоторое время для ввода данных - возможно, чтобы переопределить значения по умолчанию или прервать некоторый автоматизированный процесс, - тогда подождите сначала и проверьте доступный ввод после паузы:

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*/ }

Ответ 7

для этого можно использовать внешний флаг

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