Java: wie zum Abbrechen eines Threads Lesen aus dem System.in

Heinz Kabutz newsletter zeigt, wie Abbruch System.in liest mit einem Puffer und ExecutorService.

Nun, ich weiß nicht, ob dieser Ansatz Lecks, ist das nicht tragbar ist oder nicht-offensichtliche Nebenwirkungen. Persönlich würde ich zögern, es zu benutzen.

Sie in der Lage sein könnte, etwas zu tun mit NIO-Kanäle und Datei-Deskriptoren - meine eigenen versuche mit Ihnen nicht nachzugeben keine Ergebnisse.

JavaDoc für BufferedReader.readLine:

Gibt:
Eine Zeichenfolge, die den Inhalt der Zeile, nicht einschließlich
line-Kündigung-Zeichen oder null
wenn das Ende des Streams wurde
erreicht

Basierend auf dieser, ich glaube nicht, dass es jemals wieder null (kann System.in eigentlich geschlossen werden, ich glaube nicht, dass es jemals zurückkehrt Ende stream???), also die while-Schleife nicht beendet. Der übliche Weg zu stoppen, ein thread ist entweder eine Boolesche variable in einer Schleife, Bedingung und ändern Sie es von außerhalb des Threads, oder rufen Sie die Thread-Objekte' interrupt() -Methode (funktioniert nur, wenn der thread wait():ing oder sleep():ing, oder in einer blockierenden Methode throws InterruptedException). Sie können auch überprüfen, ob der Faden unterbrochen wurde, mit isInterrupted().

Edit: Hier ist eine einfache Implementierung unter Verwendung isInterrupted() und interrupt(). Der main-thread wartet 5 Sekunden, bevor die Unterbrechung der worker-thread. In diesem Fall worker-thread ist im Grunde busy-waiting, also es ist nicht so gut (Schleifen alle die Zeit und überprüfen stdin.ready() könnten Sie natürlich lassen Sie den worker-thread schlafen für eine Weile, wenn keine weitere Eingabe bereit):

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

}

Es scheint, gibt es keinen Weg, um tatsächlich zu unterbrechen BufferedReader wenn es blockiert readline, oder zumindest konnte ich nicht finden (mit System.in).

Was ist die Definition eines Feldes in deinem obigen thread-Klasse definition wie:

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