Java: как прервать чтение потока из System.in - PullRequest
Новая
       3

Java: как прервать чтение потока из System.in

14 голосов
/ 15 мая 2011

У меня есть поток Java: 

class MyThread extends Thread {
  @Override
  public void run() {
    BufferedReader stdin =
        new BufferedReader(new InputStreamReader(System.in));
    String msg;
    try {
      while ((msg = stdin.readLine()) != null) {
        System.out.println("Got: " + msg);
      }
      System.out.println("Aborted.");
    } catch (IOException ex) {
      ex.printStackTrace();
    }
  }
}

}

В другом потоке, как прервать вызов stdin.readline() в этом потоке, чтобы этот поток печатал Aborted.? Я пробовал System.in.close(), но это не имеет никакого значения, stdin.readline() все еще блокирует.

Меня интересуют решения без

  • занят ожидания (потому что это сжигает 100% процессора);
  • sleep (потому что тогда программа не отвечает мгновенно на System.in).

Ответы [ 6 ]

8 голосов
/ 15 мая 2011

Информационный бюллетень Хайнца Кабуца показывает, как прервать System.in чтения с использованием буфера и ExecutorService.

Теперь я не понимаюне знаю, протекает ли этот подход, не переносим или имеет неочевидные побочные эффекты.Лично я не хотел бы его использовать.

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

4 голосов
/ 13 декабря 2011

Как насчет ... 

private static BufferedReader stdInCh = new BufferedReader(
    new InputStreamReader(Channels.newInputStream((
    new FileInputStream(FileDescriptor.in)).getChannel())));

Поток, в котором вызывается stdInch.readline(), теперь прерван, и readline () выдаст java.nio.channels.ClosedByInterruptException.

2 голосов
/ 15 мая 2011

Моя первая реакция заключается в том, что поток и System.in действительно не идут вместе.

Итак, сначала разделим это так, чтобы код потока не касался статики, включая System.in.

Поток читает из InputStream и переходит в буфер.Передайте InputStream в существующий поток, который читает из буфера, но также проверяет, что вы не прервали.

1 голос
/ 15 мая 2011

JavaDoc для BufferedReader.readLine :

Возвраты: строка, содержащая содержимое строки, не включая символы окончания строки, или ноль, если конецдостигнут поток

Исходя из этого, я не думаю, что он когда-либо вернет ноль (может ли System.in быть фактически закрытым, я не думаю, что он когда-либо вернет конец потока?), так что цикл while не завершится.Обычный способ остановить поток - либо использовать булеву переменную в условии цикла и изменить ее извне потока, либо вызвать метод interrupt () -объекта объекта Thread (работает только в том случае, если поток является wait (): ing илиsleep (): ing или в методе блокировки, который генерирует исключение InterruptedException).Вы также можете проверить, был ли поток прерван с помощью isInterrupted () .

Редактировать: Вот простая реализация, использующая isInterrupted() и interrupt().Основной поток ждет 5 секунд, прежде чем прерывать рабочий поток.В этом случае рабочий поток в основном занят ожиданием, так что это не так уж хорошо (все время цикл и проверка stdin.ready(), вы, конечно, можете оставить рабочий поток на некоторое время в спящем режиме, если вход не готов): 

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;


public class MyThreadTest
{
    public static void main(String[] args)
    {
        MyThread myThread = new MyThread();
        myThread.start();

        try
        {
            Thread.sleep(5000);
        }
        catch(InterruptedException e)
        {
            //Do nothing
        }

        myThread.interrupt();

    }

    private static class MyThread extends Thread
    {       
        @Override
        public void run()
        {
            BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
            String msg;

            while(!isInterrupted())
            {
                try
                {
                    if(stdin.ready())
                    {
                        msg = stdin.readLine();
                        System.out.println("Got: " + msg);
                    }
                }
                catch(IOException e)
                {
                    e.printStackTrace();
                }
            }           
            System.out.println("Aborted.");
        }
    }

}

Кажется, что нет способа фактически прервать BufferedReader, если он заблокирован на readline, или, по крайней мере, я не смог его найти (используя System.in).

0 голосов
/ 15 мая 2011

Вы пробовали: 

Thread myThread = new MyThread();
myThread.start();
// your code.
myThread.interrupt();

Метод прерывания создает исключение InterrupedtException, после которого вы можете обработать код.

0 голосов
/ 15 мая 2011

Как насчет определения поля в приведенном выше определении класса потока, например: 

class MyThread extends Thread {   

  protected AtomicBoolean abortThread = new AtomicBoolean(false);

  public void doAbort()
  {
    this.abortThread.set(true);
  }

  @Override   public void run() 
  { 
    ...
    if (this.abortThread.get())
    {
      ...something like break loop...
    }
  }
}
...