So unterbrechen Sie einen laufenden Thread in Java (3)

E/A-Vorgang unterbrechen

Was passiert jedoch, wenn der Thread blockiert ist, während der E/A-Vorgang ausgeführt wird? E/A-Vorgänge können Threads für längere Zeit blockieren, insbesondere wenn Netzwerkanwendungen beteiligt sind. Beispielsweise muss möglicherweise ein Server auf eine Anfrage warten oder eine Netzwerkanwendung muss möglicherweise auf eine Antwort von einem Remote-Host warten.

Wenn Sie Kanäle verwenden (dies ist die neue I/O-API, die in Java 1.4 eingeführt wurde), dann erhält der blockierte Thread eine ClosedByInterruptException-Ausnahme. Wenn dies der Fall ist, ist die Logik des Codes dieselbe wie im dritten Beispiel, nur die Ausnahme ist anders.

Möglicherweise verwenden Sie jedoch traditionelle E/A, die es vor Java 1.0 gab und die mehr Arbeit erfordert. In diesem Fall funktioniert Thread.interrupt() nicht, da der Thread den blockierten Zustand nicht verlässt. Listing D beschreibt dieses Verhalten. Obwohl interrupt() aufgerufen wird, verlässt der Thread den blockierten Zustand nicht.

Listing D
import java.io.*;
class Example4 extends Thread {
  public static void main( String args[] ) throws Exception {
    Example4 thread = new Example4();
   System.out.println( "Starting thread..." );
   thread.start();
   Thread.sleep( 3000 );
   System.out.println( "Interrupting thread..." );
   thread.interrupt();
   Thread.sleep( 3000 );
   System.out.println( "Stopping application..." );
   //System.exit( 0 );
  }
  public void run() {
   ServerSocket socket;
    try {
      socket = new ServerSocket(7856);
    } catch ( IOException e ) {
     System.out.println( "Could not create the socket..." );
      return;
    }
    while ( true ) {
     System.out.println( "Waiting for connection..." );
      try {
       Socket sock = socket.accept();
      } catch ( IOException e ) {
      System.out.println( "accept() failed or interrupted..." );
      }
    }
  }
}

Glücklicherweise bietet die Java-Plattform eine Lösung für diese Situation, nämlich den Aufruf der close()-Methode des Sockets, der den Thread blockiert. Wenn der Thread in diesem Fall durch eine E/A-Operation blockiert wird, empfängt der Thread eine SocketException, was der Verwendung der Interrupt()-Methode zum Auslösen einer InterruptedException sehr ähnlich ist.

Zu beachten ist lediglich, dass ein Verweis auf den Socket vorhanden sein muss und nur so die Methode close() aufgerufen werden kann. Dies bedeutet, dass das Socket-Objekt gemeinsam genutzt werden muss. Listing E beschreibt diese Situation. Die Lauflogik ist dieselbe wie im vorherigen Beispiel.

Listing E
import java.net.*;
import java.io.*;
class Example5 extends Thread {
  volatile boolean stop = false;
  volatile ServerSocket socket;
  public static void main( String args[] ) throws Exception {
    Example5 thread = new Example5();
   System.out.println( "Starting thread..." );
   thread.start();
   Thread.sleep( 3000 );
   System.out.println( "Asking thread to stop..." );
   thread.stop = true;
   thread.socket.close();
   Thread.sleep( 3000 );
   System.out.println( "Stopping application..." );
   //System.exit( 0 );
  }
  public void run() {
    try {
      socket = new ServerSocket(7856);
    } catch ( IOException e ) {
     System.out.println( "Could not create the socket..." );
      return;
    }
    while ( !stop ) {
     System.out.println( "Waiting for connection..." );
      try {
       Socket sock = socket.accept();
      } catch ( IOException e ) {
      System.out.println( "accept() failed or interrupted..." );
      }
    }
   System.out.println( "Thread exiting under request..." );
  }
}

Das Folgende ist die Ausgabe nach der Ausführung des Codes in Listing E:

Starting thread...
Waiting for connection...
Asking thread to stop...
accept() failed or interrupted...
Thread exiting under request...
Stopping application...

Multithreading ist ein leistungsstarkes Tool, das jedoch eine Reihe von Schwierigkeiten mit sich bringt. Eine davon ist, wie man einen laufenden Thread unterbricht. Bei ordnungsgemäßer Implementierung ist das Unterbrechen von Threads mithilfe der oben genannten Techniken einfacher als die Verwendung der bereits auf der Java-Plattform bereitgestellten Inline-Operationen.

Das Obige ist der Inhalt zum Unterbrechen eines laufenden Threads (3) in Java. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website (www.php.cn).