Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Parasoft Jtest 2021.1

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 thread A few 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

  • As a remediation measure, catching the ThreadDeath exception on the other hand can itself ensnarl multithreaded code. For one, the exception can be thrown anywhere making it difficult to trace and recover from the exceptional condition effectively. Also, there is nothing stopping a thread from throwing another ThreadDeath exception while recovery is in progress.

Noncompliant Code Example

This noncompliant code example shows a thread that forcefully comes to a halt when the Thread.stop() method is invoked. Neither the catch nor the finally block is executed. Needless to say, any monitors that are held are immediately released, leaving the object in a delicate state.

Code Block
bgColor#FFcccc

class BadStop implements Runnable {
  public void run() {
    try {
      Thread.currentThread().sleep(1000);
    } catch(InterruptedException ie) { // Not executed 
        System.out.println("Performing cleanup"); 
    } finally { // Not executed
        System.out.println("Closing resources"); 
    }       
    System.out.println("Done!");
  }
}

class Controller {
  public static void main(String[] args) {
    Thread t = new Thread(new BadStop());
    t.start();  
    t.interrupt(); // Artificially induce an InterruptedException
    t.stop();      // Force thread cancellation
  }
}

Compliant Solution (1)

This compliant example uses a boolean flag called done to indicate whether the thread should be stopped after any necessary cleanup code has finished executing. An accessor method shutdown() is used to set the flag to true, after which the thread can start the cancellation process. The done flag is also set immediately after the execution of the finally block's resource clean-up statements so that the system does not continue relinquishing resources that it has already released, in the event of the done flag staying false.

. 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 pseudorandom numbers. The thread is forcefully stopped after a given amount of time.

Code Block
bgColor#FFcccc
public final class Container implements Runnable {
  private final Vector<Integer> vector = new Vector<Integer>(1000);

  public Vector<Integer> getVector
Code Block
bgColor#ccccff

class ControlledStop implements Runnable{
  protected volatile boolean done = false;
  public void run() {
    while(!done) {return vector;
      try {
        Thread.currentThread().sleep(1000);}

  @Override public synchronized void } catch(InterruptedException ierun() { 
    Random number =    System.out.println(&quot;Interrupted Exception&quot;new Random(123L);
    int i     // Handle the exception 
      } finally { 
          System.out.println(&quot;Closing resources&quot;); = vector.capacity();
    while (i >    done = true; 0) {
      }
    } 
    System.out.println(&quot;Done!&quot;vector.add(number.nextInt(100));
  }

  protected void shutdown(){ i--;
    done = true;}
  }
}

class Controller {
  public static void main(String[] args) throws InterruptedException {  
    ControlledStopThread cthread = new ControlledStop();
    Thread t = Thread(new ThreadContainer(c));
    tthread.start();
    t.interrupt();       // Artificially induce an InterruptedException
    Thread.sleep(10005000);  // Wait for some time to allow the exception
                         // to be caught (demonstration only)
    c.shutdownthread.stop();
  }
}

Compliant Solution (2)

Because the Vector class is thread-safe, operations performed by multiple threads on its shared instance are expected to leave it in a consistent state. For instance, the Vector.size() method always returns the correct number of elements in the vector, even after concurrent changes to the vector, because the vector instance uses its own intrinsic lock to prevent other threads from accessing it while its state is temporarily inconsistent.

However, 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

method causes the thread to stop what it is doing and throw a 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 solution uses a volatile flag to request thread termination. The shutdown() accessor method is used to set the flag to true. The thread's run() method polls the done flag and terminates when it is setThis noncompliant code example uses the advice suggested in the previous compliant solution. Unfortunately, this does not help in terminating the thread because it is blocked on some network IO because of the readLine() method. The boolean flag trick does not work in such cases; a good alternative to end the thread is required.

Code Block
bgColor#FFcccc#ccccff
public final 
class StopSocketContainer extendsimplements ThreadRunnable {
   protected Socket sprivate final Vector<Integer> vector = new Vector<Integer>(1000);
  protectedprivate volatile boolean done = false;

  public voidVector<Integer> rungetVector() { 
    while(!done) {return vector;
  }

  public void tryshutdown() {
      done  s = new Socket(&quot;somehost&quot;, 25);
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String s = null;
        while((s = br.readLine()) != null) { true;
  }

  @Override public synchronized void run() {
    Random number =    // Blocks until end of stream (null)new Random(123L);
    int i   }
        System.out.println(&quot;Blocked, will not get executed until some data is received. &quot; + s= vector.capacity();
     while } catch (IOException ie) { 
          System.out.println(&quot;IO Exception&quot;); 
          // Handle the exception
      } finally (!done && i > 0) {
          System.out.println(&quot;Closing resources&quot;vector.add(number.nextInt(100));
          done = true;
      }i--;
    }
  }  

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

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

Compliant Solution (Interruptible)

This In this compliant solution simply closes the socket connection, both using the shutdownThread.interrupt() 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 immediatelyis 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.

Code Block
bgColor#ccccff

class StopSocket extends Thread {
  protected Socket s;
  public voidfinal run()class {Container 
implements  Runnable  try {
  private final Vector<Integer>  svector = new Socket(&quot;somehost&quot;, 25);
      BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));Vector<Integer>(1000);

  public    String s = null;
      while((s = br.readLine()) != nullVector<Integer> getVector() { 
        // Blocks until end of stream (null)return vector;
      }
      System.out.println(&quot;Blocked, will not get executed until some data is received. &quot; + s);
  @Override public }synchronized catchvoid run(IOException ie) { 
    Random number = new System.out.println(&quot;IO Exception&quot;Random(123L);
    int i   // Handle the exception 
    } finally {
        System.out.println(&quot;Closing resources&quot;= vector.capacity();
        try {
          if(s != null)
            s.close();
        } catch (IOException e) { /* Forward to handler */ }while (!Thread.interrupted() && i > 0) {
    }
  }

  public void shutdown() throws IOException {  vector.add(number.nextInt(100));
    if(s != null) i--;
      s.close();}
  }
}

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

A 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

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

Rule

Severity

Likelihood

Remediation Cost

Priority

Level

CON35

THI05-J

low

Low

probable

Probable

medium

Medium

P4

L3

Automated Detection

...

TODO

Related Vulnerabilities

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

References

ToolVersionCheckerDescription
Parasoft Jtest
Include Page
Parasoft_V
Parasoft_V
CERT.THI05.THRDAvoid calling unsafe deprecated methods of 'Thread' and 'Runtime'

Related Guidelines

Android Implementation Details

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

Bibliography

[API 2006]

Class Thread, Method stop
InterfaceExecutorService

[Darwin 2004]

Section 24.3, "Stopping a Thread"

[Goetz 2006]

Chapter 7, "Cancellation and Shutdown"

[JavaThreads 2004]

Section 2.4, "Two Approaches to Stopping a Thread"

[JDK7 2008]

Concurrency Utilities, More information: Java Thread Primitive Deprecation

[JPL 2006]

Section 14.12.1, "Don't Stop"
Section 23.3.3, "Shutdown Strategies"

[Sun 1999]



...

Image Added Image Added Image Added

Wiki Markup
\[[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 05|AA. Java References#JPL 05]\] 14.12.1. Don't stop
\[[JavaThreads 04|AA. Java References#JavaThreads 04]\] 2.4 Two Approaches to Stopping a Thread

CON34-J. Avoid deadlock by requesting locks in the proper order&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;11. Concurrency (CON)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;CON36-J. Always synchronize on the appropriate object