Page History

Threads always preserve class invariants when they are allowed to exit normally. Programmers often try attempt to forcefully terminate threads abruptly when they believe that the task is accomplishedcomplete, the request has been canceled, or the program needs to quickly shutdown. or Java Virtual Machine (JVM) must shut down expeditiously.

Certain A few thread APIs were introduced to facilitate thread suspension, resumption, and termination but were later deprecated due to because of inherent design weaknesses. The For example, the Thread.stop() method is one example. It throws causes the thread to immediately throw a ThreadDeath exception to stop , which usually stops the thread. Two cases arise:

...

More information about deprecated methods is available in MET02-J. Do not use deprecated or obsolete classes or methods.

Invoking Thread.stop()

...

results in the release of all locks a thread has acquired, potentially exposing the objects protected by those locks when those objects are in an inconsistent state. The thread might catch the ThreadDeath exception and use a finally block in an attempt to repair the inconsistent object or objects. However, doing so requires careful inspection of all synchronized methods and blocks because a ThreadDeath exception can be thrown at any point during the thread's execution. Furthermore, code must be protected from ThreadDeath exceptions that might occur while executing catch or finally blocks [Sun 1999]. Consequently, programs must not invoke Thread.stop().

Removing the java.lang.RuntimePermission stopThread permission from the security policy file prevents threads from being stopped using the Thread.stop() method. Although this approach guarantees that the program cannot use the Thread.stop() method, it is nevertheless strongly discouraged. Existing trusted, custom-developed code that uses the Thread.stop() method presumably depends on the ability of the system to perform this action. Furthermore, the system might fail to correctly handle the resulting security exception. Additionally, third-party libraries may also depend on use of the Thread.stop() method.

Refer to ERR09-J. Do not allow untrusted code to terminate the JVM for information on preventing data corruption when the JVM is abruptly shut down.

Noncompliant Code Example (Deprecated Thread.stop())

This noncompliant code example shows a thread that fills a vector with stringspseudorandom numbers. The thread is shut down forcefully stopped after a fixed period given amount of time time.

public final class Container implements Runnable {
  private final Vector<String>Vector<Integer> vector = new Vector<String>Vector<Integer>(1000);

  public Vector<String>Vector<Integer> getVector() {
    return vector;
  }

  
@Override public publicsynchronized void run() {
    StringRandom stringnumber = null;
    do {
      System.out.println("Enter another string"new Random(123L);
    int  BufferedReader ini = new BufferedReader(new InputStreamReader(System.in)vector.capacity();
    while  try(i > 0) {
        string = in.readLine()vector.add(number.nextInt(100));
      } catch (IOException e) {
        // Forward to handler
      }
      vector.add(string)i--;
    } while (!"END".equals(string));
  }

  public static void main(String[] args) throws InterruptedException {
    ContainerThread cthread = new Container();
    Thread thread = Thread(new ThreadContainer(c));
    thread.start();
    Thread.sleep(5000);
    thread.stop();
  }
}

Since vector Because the Vector class is thread-safe, it is only accessible to this program while operations performed by multiple threads on its shared instance are expected to leave it in a consistent state. That isFor instance, the Vector.size() method always reflects returns the true correct number of elements in the vector. When a new element is added , even after concurrent changes to the vector, it adjusts its internal data and its internal data is temporarily inconsistent. But because the vector instance uses its own intrinsic lock to prevent other threads from accessing it while its state is temporarily inconsistent.unmigrated-wiki-markup

However, the {{Thread.stop()}} method causes the thread to stop what it is doing and throw a {{ThreadDeath}} object, and also to release all locks \[[API 06|AA. Java References#API 06]\]. If the thread is currently adding a new string to the vector when it gets stopped, then the vector may become visible while in an inconsistent state. This might mean, for instance, that {{Vector.size()}} is 3 while the vector actually only contains 2 elements ThreadDeath exception. All acquired locks are subsequently released [API 2014]. If the thread were in the process of adding a new integer to the vector when it was stopped, the vector would become accessible while it is in an inconsistent state. For example, this could result in Vector.size() returning an incorrect element count because the element count is incremented after adding the element.

Compliant Solution (volatile flag)

This compliant example stops the thread by making use of solution uses a volatile flag . An accessor method to request thread termination. The shutdown() accessor method is used to set the flag to true, after which the thread can start the cancellation process. The thread's run() method polls the done flag and terminates when it is set.

public final class Container implements Runnable {
  private final Vector<String>Vector<Integer> vector = new Vector<String>Vector<Integer>(1000);
  
  private volatile boolean done = false;
  
  public Vector<String>Vector<Integer> getVector() {
    return vector;
  }
  
  public void shutdown() {
	    done = true;
  }

  @Override public synchronized void run() {
    StringRandom stringnumber = null;
    do {
      System.out.println("Enter another string");
      BufferedReader in = new BufferedReader(new InputStreamReader(System.in))new Random(123L);
      try {
        stringint i = invector.readLinecapacity();
    while (!done }&& catchi (IOException> e0) {
        // Forward to handler
      }
      vector.add(string(number.nextInt(100));
    } while (!done && !"END".equals(string));  i--;
    }
  }

  public static void main(String[] args) throws InterruptedException {
    Container ccontainer = new Container();
    Thread thread = new Thread(ccontainer);
    thread.start();
    Thread.sleep(5000);
    ccontainer.shutdown();
    return;
  }
}

Compliant Solution (Interruptible)

This compliant example stops the thread by making use of a volatile flag. An accessor method shutdown() is used to set the flag to true, after which the thread can start the cancellation processIn this compliant solution, the Thread.interrupt() method is called from main() to terminate the thread. Invoking Thread.interrupt() sets an internal interrupt status flag. The thread polls that flag using the Thread.interrupted() method, which both returns true if the current thread has been interrupted and clears the interrupt status flag.

public final class Container implements Runnable {
  private final Vector<String>Vector<Integer> vector = new Vector<String>Vector<Integer>(1000);
  
  public Vector<String>Vector<Integer> getVector() {
    	return vector;
  }

  @Override public synchronized void run() {
    StringRandom stringnumber = null;
    do {
      System.out.println("Enter another string");
      BufferedReader in = new BufferedReader(new InputStreamReader(System.in)new Random(123L);
    int  try {
        string = in.readLine();
      } catch (IOException e) {
        // Forward to handler
      }
      vector.add(stringi = vector.capacity();
    } while (!Thread.interrupted() && !"END".equals(string));
  }

  public static void main(String[] args) throws InterruptedException i > 0) {
    Container c = new Container();
    Thread thread = new Thread(c);
    thread.start();
    Thread.sleep(5000);
    thread.interrupt();
  }
}

Compliant Solution (RuntimePermission stopThread)

Remove the default permission java.lang.RuntimePermission stopThread from the security policy file to deny the Thread.stop() invoking code, the required privileges.

Noncompliant Code Example (blocking IO)

This noncompliant code example uses the advice suggested in the previous compliant solution. However, this does not help in terminating the thread because it is blocked on some network IO as a consequence of using the readLine() method.

class StopSocket extends Thread {
  private Socket s;
  private volatile boolean done = false;
  
  public void run() { 
    while(!done) {
      try {
        s = new Socket("somehost", 25);
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String s = null;
        while((s = br.readLine()) != null) { 
          // Blocks until end of stream (null)
        }
      } catch (IOException ie) { 
          // Forward to handler
      } finally {
          done = true;
      }
    }
  }  

  public void shutdown() throws IOException {
    done = true;
  }
}

class Controller {
   vector.add(number.nextInt(100));
      i--;
    }
  }

  public static void main(String[] args) throws InterruptedException, IOException {
    Container StopSocket ssc = new StopSocketContainer();
     Thread tthread = new Thread(ssc);
     tthread.start();
     Thread.sleep(10005000); 
     ssthread.shutdowninterrupt();
  }
}

A Socket connection is not affected by the InterruptedException that results with the use of the Thread.interrupt() method. The boolean flag solution does not work in such cases.

Compliant Solution (close socket connection)

This compliant solution closes the socket connection, both using the shutdown() method as well as the finally block. As a result, the thread is bound to stop due to a SocketException. Note that there is no way to keep the connection alive if the thread is to be cleanly halted immediately.

class StopSocket extends Thread {
  private Socket s;
 
  public void run() { 
    try {
      s = new Socket("somehost", 25);
      BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
      String s = null;
      while((s = br.readLine()) != null) { 
        // Blocks until end of stream (null)
      }
    } catch (IOException ie) { 
        // Handle the exception 
    } finally {
        try {
          if(s != null)
            s.close();
        } catch (IOException e) { /* Forward to handler */ }
    }
  }

  public void shutdown() throws IOException {
    if(s != null)
      s.close();
  }
}

class Controller {
  public static void main(String[] args) throws InterruptedException, IOException {
    StopSocket ss = new StopSocket();
    Thread t = new Thread(ss);
    t.start();
    Thread.sleep(1000); 
    ss.shutdown();
  }
}

A boolean flag can be used (as described earlier) if additional clean-up operations need to be performed.

Compliant Solution (2) (interruptible channel)

This compliant solution uses an interruptible channel, SocketChannel instead of a Socket connection. If the thread performing the network IO is interrupted using the Thread.interrupt() method, for instance, while reading the data, the thread receives a ClosedByInterruptException and the channel is closed immediately. The thread's interrupt status is also set.

class StopSocket extends Thread {
  private volatile boolean done = false;
  public void run() { 
    while(!done) {
      try {
    	InetSocketAddress addr = new InetSocketAddress("somehost", 25);
        SocketChannel sc = SocketChannel.open(addr);
        ByteBuffer buf = ByteBuffer.allocate(1024);
        sc.read(buf);
        // ...
      } catch (IOException ie) {  
          // Handle the exception
      } finally {
          done = true;
      }
    }
  }  

  public void shutdown() throws IOException {
    done = true;
  }
}

Risk Assessment

thread may use interruption for performing tasks other than cancellation and shutdown. Consequently, a thread should be interrupted only when its interruption policy is known in advance. Failure to do so can result in failed interruption requests.

Risk Assessment

Forcing a thread to stop can result in inconsistent object state. Critical resources could Trying to force thread shutdown can result in inconsistent object state and corrupt the object. Critical resources may also leak if cleanup operations are not carried out as required.

Automated Detection

...

TODO

Related Vulnerabilities

Search for vulnerabilities resulting from the violation of this rule on the CERT website.

References

Tool	Version	Checker	Description
Parasoft Jtest	Include Page Parasoft_V Parasoft_V	CERT.THI05.THRD	Avoid calling unsafe deprecated methods of 'Thread' and 'Runtime'

Related Guidelines

Android Implementation Details

On Android, Thread.stop() was deprecated in API level 1.

Bibliography

...

Image Added Image Added Image Added

\[[API 06|AA. Java References#API 06]\] Class Thread, method {{stop}}
\[[Darwin 04|AA. Java References#Darwin 04]\] 24.3 Stopping a Thread
\[[JDK7 08|AA. Java References#JDK7 08]\] Concurrency Utilities, More information: Java Thread Primitive Deprecation 
\[[JPL 06|AA. Java References#JPL 06]\] 14.12.1. Don't stop and 23.3.3. Shutdown Strategies
\[[JavaThreads 04|AA. Java References#JavaThreads 04]\] 2.4 Two Approaches to Stopping a Thread

CON12-J. Avoid deadlock by requesting and releasing locks in the same order      11. Concurrency (CON)      VOID CON14-J. Ensure atomicity of 64-bit operations