Threads always preserve class invariants when they are allowed to exit normally. Programmers often try attempt to terminate threads abruptly when they believe that the task is accomplished, the request has been canceled, or the program or JVM needs to quickly must shut down expeditiously.
A few Certain thread APIs were introduced to facilitate thread suspension, resumption, and termination but were later deprecated because of due to inherent design weaknesses. For example, the Thread.stop()
method causes the thread to immediately throw a ThreadDeath
exception, which usually stops the thread.
Wiki Markup |
---|
Invoking {{Thread.stop()}} results in the release of all the locks a thread has acquired, which could corrupt the state of the object potentially exposing the objects protected by those locks when those objects are in an inconsistent state. The thread could catch the {{ThreadDeath}} exception and use a {{finally}} block in an attempt to repair the inconsistent object or objects. However, this requires careful inspection of all the 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 could result when executing {{catch}} or {{finally}} blocks \[[Sun 1999|AA. Bibliography#Sun 99]\]. Consequently, use of the {{Thread.stop()}} method is forbidden. |
More information about deprecated methods is available in rule MET15-J. Do not use deprecated or obsolete classes or methods. Also, refer to rule ERR09-J. Do not allow untrusted code to terminate the JVM for information on preventing data corruption when the JVM is shut down abruptly.
...
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 in the face of concurrent changes to the vector. This is , because the vector instance uses its own intrinsic lock to prevent other threads from accessing it while its state is temporarily inconsistent.
Wiki Markup |
---|
However, the {{Thread.stop()}} method causes the thread to stop what it is doing and throw a {{ThreadDeath}} exception. All acquired locks are subsequently released \[[API 2006|AA. Bibliography#API 06]\]. If the thread iswere in the process of adding a new integer to the vector when it iswas stopped, the vector maywould become accessible while it is in an inconsistent state. This cancould result in {{Vector.size()}} returning an incorrect element count, for example, because the element count is incremented after adding the element. |
...
This compliant solution uses a volatile
flag to terminate the 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 becomes trueis 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(); } } |
...
In 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 also 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(); } } |
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 do so can result in failed interruption requests.
...
Removing the default permission java.lang.RuntimePermission
stopThread
permission from the security policy file prevents threads from being stopped using the Thread.stop()
method. This approach is not recommended discouraged for trusted, custom-developed code that uses that method because the existing design presumably depends upon the ability of the system to perform this action. Furthermore, the system might not be designed fail to properly correctly handle the resulting exception. In these cases, it is preferable to programmers should implement an alternate design approach corresponding to another compliant solution one of the other compliant solutions described in this rule.
Risk Assessment
...
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.
...
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="17703b3ebf01ef2b-e70a0d6c-43354048-8b34bd42-a4190378734327773b08eb1b"><ac:plain-text-body><![CDATA[ | [[API 2006 | AA. Bibliography#API 06]] | Class Thread, method | ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="90cf50a3cdd470a0-a9a888ce-4fd244a4-989e8252-f9253ca0d832454de8a019c8"><ac:plain-text-body><![CDATA[ | [[Sun 1999 | AA. Bibliography#Sun 99]] |
| ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="7d09594fb7162dd4-0396b963-4d704ae7-95f381b6-b744bac8cacccea3958fba05"><ac:plain-text-body><![CDATA[ | [[Darwin 2004 | AA. Bibliography#Darwin 04]] | 24.3 Stopping a Thread | ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="cff0cc387dcbb503-9b46b220-4bdf4b45-ba5c9469-b829dbc9f05527556fcf5110"><ac:plain-text-body><![CDATA[ | [[JDK7 2008 | AA. Bibliography#JDK7 08]] | Concurrency Utilities, More information: Java Thread Primitive Deprecation | ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="0802e0f9105fd09d-42b4e350-43234899-b42e96f6-f35c2108e6f89eb2182db656"><ac:plain-text-body><![CDATA[ | [[JPL 2006 | AA. Bibliography#JPL 06]] | 14.12.1. Don't stop and 23.3.3. Shutdown Strategies | ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="4b396a3d4fb0d403-0ca2754d-46ec4b84-87c8bae6-d21643475f960389da7f71ee"><ac:plain-text-body><![CDATA[ | [[JavaThreads 2004 | AA. Bibliography#JavaThreads 04]] | 2.4 Two Approaches to Stopping a Thread | ]]></ac:plain-text-body></ac:structured-macro> |
<ac:structured-macro ac:name="unmigrated-wiki-markup" ac:schema-version="1" ac:macro-id="b88e0bec7b8b24b6-6944e4eb-4d9f4de4-b4dc97aa-a4b393ac90cefcb78bd63f3b"><ac:plain-text-body><![CDATA[ | [[Goetz 2006 | AA. Bibliography#Goetz 06]] | Chapter 7: Cancellation and shutdown | ]]></ac:plain-text-body></ac:structured-macro> |
...