Threads always preserve class invariants when they are allowed to exit normally, as long as the specification is followed. 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 or JVM needs to quickly Java Virtual Machine (JVM) must shut down expeditiously.
A few Certain thread APIs were introduced to facilitate thread suspension, resumption, and termination but were later deprecated 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
- 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 effectively recover from the exceptional condition. Also, there is nothing stopping a thread from throwing anotherThreadDeath
exception while recovery is in progress.
More information about deprecated methods is available in MET15-J. Do not use deprecated or obsolete methods. Also, refer to EXC09-J. Prevent inadvertent calls to System.exit() or forced shutdown 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 | ||
---|---|---|
| ||
public final class Container implements Runnable { private final Vector<Integer> vector = new Vector<Integer>(1000); public Vector<Integer> getVector() { return vector; } @Override public synchronized void run() { Random number = new Random(123L); int i = vector.capacity(); while (i > 0) { vector.add(number.nextInt(100)); i--; } } public static void main(String[] args) throws InterruptedException { Thread thread = new Thread(new Container()); thread.start(); Thread.sleep(5000); thread.stop(); } } |
Because the Vector
class Vector
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 when an element is added or removed. This is , 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, the {{ Wiki Markup Thread.stop()
}} method causes the thread to stop what it is doing and throw a {{ThreadDeath
}} exception. All acquired locks are subsequently released \ [[API 06|AA. Java References#API 06]\]. If the thread is in the process of adding a new integer to the vector when it is stopped, the vector may become accessible while it is in an inconsistent state. For example, {{Vector.size()}} may return two even though the vector contains three elements (as the element count is incremented after adding the element)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 stop the request thread termination. An accessor method 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 becomes true
is set.
Code Block | ||
---|---|---|
| ||
public final class Container implements Runnable { private final Vector<Integer> vector = new Vector<Integer>(1000); private volatile boolean done = false; public Vector<Integer> getVector() { return vector; } public void shutdown() { done = true; } @Override public synchronized void run() { Random number = new Random(123L); int i = vector.capacity(); while (!done && i > 0) { vector.add(number.nextInt(100)); i--; } } public static void main(String[] args) throws InterruptedException { Container container = new Container(); Thread thread = new Thread(container); thread.start(); Thread.sleep(5000); container.shutdown(); } } |
Compliant Solution (Interruptible)
This In this compliant solution stops the thread , 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.interruptinterrupted()
method, which both returns true if the current thread has been interrupted and clears the interrupt status flag.
Code Block | ||
---|---|---|
| ||
public final class Container implements Runnable { private final Vector<Integer> vector = new Vector<Integer>(1000); public Vector<Integer> getVector() { return vector; } @Override public synchronized void run() { Random number = new Random(123L); int i = vector.capacity(); while (!Thread.interrupted() && i > 0) { vector.add(number.nextInt(100)); i--; } } public static void main(String[] args) throws InterruptedException { Container c = new Container(); Thread thread = new Thread(c); thread.start(); Thread.sleep(5000); thread.interrupt(); } } |
This method interrupts the current thread, however, it only stops the thread because the code polls the interrupted flag using the method Thread.interrupted()
.
Upon receiving the interruption, the interrupted status of the thread is cleared and an InterruptedException
is thrown. No guarantees are provided by the JVM on when the interruption will be detected by blocking methods such as Thread.sleep()
and Object.wait()
. A thread may use interruption for performing tasks other than cancellation and shutdown. Consequently, a thread should not be interrupted unless only when its interruption policy is known in advance. Failure to follow this advice do so can result in the corruption of mutable shared state.
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.
failed interruption requests.
Risk Assessment
Forcing a thread to stop can result in inconsistent object state. Critical resources may could also leak if clean-up cleanup operations are not carried out as required.
Rule | Severity | Likelihood | Remediation Cost | Priority | Level |
---|
THI05-J |
Low |
Probable |
Medium | P4 | L3 |
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 |
| CERT.THI05.THRD | Avoid calling unsafe deprecated methods of 'Thread' and 'Runtime' |
Related Guidelines
POS47-C. Do not use threads that can be canceled asynchronously | |
CWE-705, Incorrect Control Flow Scoping |
Android Implementation Details
On Android, Thread.stop()
was deprecated in API level 1.
Bibliography
[API 2006] | Class |
Section 24.3, "Stopping a Thread" | |
Chapter 7, "Cancellation and Shutdown" | |
Section 2.4, "Two Approaches to Stopping a Thread" | |
Concurrency Utilities, More information: Java Thread Primitive Deprecation | |
[JPL 2006] | Section 14.12.1, "Don't Stop" |
[Sun 1999] |
...
Wiki Markup |
---|
\[[API 06|AA. Java References#API 06]\] Class Thread, method {{stop}}, interface ExecutorService
\[[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
\[[Goetz 06|AA. Java References#Goetz 06]\] Chapter 7: Cancellation and shutdown |
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