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

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

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

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

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

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

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

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

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

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

JavaDoc для BufferedReader.readLine :

Исходя из этого, я не думаю, что он когда-либо вернет null (может ли System.in быть закрыт, я не думаю, что он когда-либо возвращает конец потока?), поэтому цикл while не завершится. Обычный способ остановить поток — либо использовать логическую переменную в условии цикла и изменить ее вне потока, либо вызвать метод interrupt() объекта Thread (работает, только если поток ждет():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, если он заблокирован в строке чтения, или, по крайней мере, я не смог его найти (используя System.in).

Ты пытался:

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

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

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

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