aboutsummaryrefslogtreecommitdiff
path: root/libjava/java/lang
diff options
context:
space:
mode:
authorTom Tromey <tromey@redhat.com>2002-06-18 15:40:16 +0000
committerTom Tromey <tromey@gcc.gnu.org>2002-06-18 15:40:16 +0000
commit3831381763ca5f41d6f7406d590e1e38a8531e1c (patch)
tree6b8dcd38b7dbb7c4c618080eb1958b6f042d581c /libjava/java/lang
parent0fd534ed06e92a7232b2373321f113ee8dd482c4 (diff)
downloadgcc-3831381763ca5f41d6f7406d590e1e38a8531e1c.zip
gcc-3831381763ca5f41d6f7406d590e1e38a8531e1c.tar.gz
gcc-3831381763ca5f41d6f7406d590e1e38a8531e1c.tar.bz2
javaprims.h: Updated class declaration list.
* gcj/javaprims.h: Updated class declaration list. * Makefile.in: Rebuilt. * Makefile.am (core_java_source_files): Added PropertyPermissionCollection.java. * java/lang/Thread.java (group, name): Now package-private. * java/lang/ThreadGroup.java: Re-merge with Classpath. * java/util/AbstractList.java: Likewise. * java/util/AbstractMap.java: Likewise. * java/util/Calendar.java: Likewise. * java/util/Collections.java: Likewise. * java/util/HashMap.java: Likewise. * java/util/Hashtable.java: Likewise. * java/util/LinkedHashMap.java: Likewise. * java/util/LinkedList.java: Likewise. * java/util/List.java: Likewise. * java/util/ListResourceBundle.java: Likewise. * java/util/Map.java: Likewise. * java/util/Observable.java: Likewise. * java/util/Properties.java: Likewise. * java/util/PropertyPermission.java: Likewise. * java/util/PropertyPermissionCollection.java: Likewise. * java/util/PropertyResourceBundle.java: Likewise. * java/util/Random.java: Likewise. * java/util/SimpleTimeZone.java: Likewise. * java/util/StringTokenizer.java: Likewise. * java/util/TimerTask.java: Likewise. * java/util/TreeMap.java: Likewise. * java/util/WeakHashMap.java: Likewise. * java/util/jar/Attributes.java: Likewise. * java/util/jar/JarException.java: Likewise. * java/util/jar/Manifest.java: Likewise. From-SVN: r54743
Diffstat (limited to 'libjava/java/lang')
-rw-r--r--libjava/java/lang/Thread.java4
-rw-r--r--libjava/java/lang/ThreadGroup.java1019
2 files changed, 572 insertions, 451 deletions
diff --git a/libjava/java/lang/Thread.java b/libjava/java/lang/Thread.java
index 92f74f6..af5b95f 100644
--- a/libjava/java/lang/Thread.java
+++ b/libjava/java/lang/Thread.java
@@ -301,8 +301,8 @@ public class Thread implements Runnable
public static native void yield ();
// Private data.
- private ThreadGroup group;
- private String name;
+ ThreadGroup group;
+ String name;
private Runnable runnable;
private int priority;
private boolean daemon_flag;
diff --git a/libjava/java/lang/ThreadGroup.java b/libjava/java/lang/ThreadGroup.java
index ae65f85..80f62b6 100644
--- a/libjava/java/lang/ThreadGroup.java
+++ b/libjava/java/lang/ThreadGroup.java
@@ -1,5 +1,5 @@
-/* java.lang.ThreadGroup
- Copyright (C) 1998, 2000, 2001 Free Software Foundation, Inc.
+/* ThreadGroup -- a group of Threads
+ Copyright (C) 1998, 2000, 2001, 2002 Free Software Foundation, Inc.
This file is part of GNU Classpath.
@@ -7,7 +7,7 @@ GNU Classpath is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2, or (at your option)
any later version.
-
+
GNU Classpath is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
@@ -34,166 +34,213 @@ or based on this library. If you modify this library, you may extend
this exception to your version of the library, but you are not
obligated to do so. If you do not wish to do so, delete this
exception statement from your version. */
-
+
package java.lang;
import java.util.Vector;
-import java.util.Enumeration;
-/* Written using "Java Class Libraries", 2nd edition, ISBN 0-201-31002-3
- * "The Java Language Specification", ISBN 0-201-63451-1
- * plus online API docs for JDK 1.2 from http://www.javasoft.com.
- * Status: Complete for 1.2. Some parts from the JDK 1.0 spec only are
- * not implemented.
- */
-
/**
- * ThreadGroup allows you to group Threads together. There is a
- * hierarchy of ThreadGroups, and only the initial ThreadGroup has
- * no parent. A Thread may access information about its own
- * ThreadGroup, but not its parents or others outside the tree.
+ * ThreadGroup allows you to group Threads together. There is a hierarchy
+ * of ThreadGroups, and only the initial ThreadGroup has no parent. A Thread
+ * may access information about its own ThreadGroup, but not its parents or
+ * others outside the tree.
*
* @author John Keiser
* @author Tom Tromey
* @author Bryce McKinlay
- * @version 1.2.0
- * @since JDK1.0
+ * @author Eric Blake <ebb9@email.byu.edu>
+ * @see Thread
+ * @since 1.0
+ * @status updated to 1.4
*/
-
public class ThreadGroup
{
- /* The Initial, top-level ThreadGroup. */
+ /** The Initial, top-level ThreadGroup. */
static ThreadGroup root = new ThreadGroup();
- /* This flag is set if an uncaught exception occurs. The runtime should
- check this and exit with an error status if it is set. */
- static boolean had_uncaught_exception = false;
- private ThreadGroup parent;
- private String name;
- private Vector threads = new Vector();
+ /**
+ * This flag is set if an uncaught exception occurs. The runtime should
+ * check this and exit with an error status if it is set.
+ */
+ static boolean had_uncaught_exception;
+
+ /** The parent thread group. */
+ private final ThreadGroup parent;
+
+ /** The group name, non-null. */
+ final String name;
+
+ /** The threads in the group. */
+ private final Vector threads = new Vector();
+
+ /** Child thread groups, or null when this group is destroyed. */
private Vector groups = new Vector();
+
+ /** If all threads in the group are daemons. */
private boolean daemon_flag = false;
- private int maxpri = Thread.MAX_PRIORITY;
+ /** The maximum group priority. */
+ private int maxpri;
+
+ /**
+ * Hidden constructor to build the root node.
+ */
private ThreadGroup()
{
- name = "main";
+ name = "main";
+ parent = null;
+ maxpri = Thread.MAX_PRIORITY;
}
- /** Create a new ThreadGroup using the given name and the
- * current thread's ThreadGroup as a parent.
- * @param name the name to use for the ThreadGroup.
+ /**
+ * Create a new ThreadGroup using the given name and the current thread's
+ * ThreadGroup as a parent. There may be a security check,
+ * <code>checkAccess</code>.
+ *
+ * @param name the name to use for the ThreadGroup
+ * @throws SecurityException if the current thread cannot create a group
+ * @see #checkAccess()
*/
public ThreadGroup(String name)
{
- this (Thread.currentThread().getThreadGroup(), name);
+ this(Thread.currentThread().group, name);
}
- /** Create a new ThreadGroup using the given name and
- * parent group.
- * @param name the name to use for the ThreadGroup.
- * @param parent the ThreadGroup to use as a parent.
- * @exception NullPointerException if parent is null.
- * @exception SecurityException if you cannot change
- * the intended parent group.
+ /**
+ * Create a new ThreadGroup using the given name and parent group. The new
+ * group inherits the maximum priority and daemon status of its parent
+ * group. There may be a security check, <code>checkAccess</code>.
+ *
+ * @param name the name to use for the ThreadGroup
+ * @param parent the ThreadGroup to use as a parent
+ * @throws NullPointerException if parent is null
+ * @throws SecurityException if the current thread cannot create a group
+ * @throws IllegalThreadStateException if the parent is destroyed
+ * @see #checkAccess()
*/
public ThreadGroup(ThreadGroup parent, String name)
{
parent.checkAccess();
this.parent = parent;
- if (parent.isDestroyed())
- throw new IllegalArgumentException ();
this.name = name;
maxpri = parent.maxpri;
daemon_flag = parent.daemon_flag;
- parent.addGroup(this);
+ synchronized (parent)
+ {
+ if (parent.groups == null)
+ throw new IllegalThreadStateException();
+ parent.groups.add(this);
+ }
}
- /** Get the name of this ThreadGroup.
- * @return the name of this ThreadGroup.
+ /**
+ * Get the name of this ThreadGroup.
+ *
+ * @return the name of this ThreadGroup
*/
public final String getName()
{
return name;
}
- /** Get the parent of this ThreadGroup.
- * @return the parent of this ThreadGroup.
+ /**
+ * Get the parent of this ThreadGroup. If the parent is not null, there
+ * may be a security check, <code>checkAccess</code>.
+ *
+ * @return the parent of this ThreadGroup
+ * @throws SecurityException if permission is denied
*/
public final ThreadGroup getParent()
{
+ if (parent != null)
+ parent.checkAccess();
return parent;
}
- /** Set the maximum priority for Threads in this ThreadGroup. setMaxPriority
- * can only be used to reduce the current maximum. If maxpri
- * is greater than the current Maximum, the current value is not changed.
- * Calling this does not effect threads already in this ThreadGroup.
- * @param maxpri the new maximum priority for this ThreadGroup.
- * @exception SecurityException if you cannoy modify this ThreadGroup.
- */
- public final synchronized void setMaxPriority(int maxpri)
- {
- checkAccess();
- if (maxpri < this.maxpri
- && maxpri >= Thread.MIN_PRIORITY
- && maxpri <= Thread.MAX_PRIORITY)
- {
- this.maxpri = maxpri;
- }
- }
-
- /** Get the maximum priority of Threads in this ThreadGroup.
- * @return the maximum priority of Threads in this ThreadGroup.
+ /**
+ * Get the maximum priority of Threads in this ThreadGroup. Threads created
+ * after this call in this group may not exceed this priority.
+ *
+ * @return the maximum priority of Threads in this ThreadGroup
*/
public final int getMaxPriority()
{
return maxpri;
}
- /** Set whether this ThreadGroup is a daemon group. A daemon
- * group will be destroyed when its last thread is stopped and
- * its last thread group is destroyed.
- * @specnote The Java API docs indicate that the group is destroyed
- * when either of those happen, but that doesn't make
- * sense.
- * @param daemon whether this ThreadGroup should be a daemon group.
- * @exception SecurityException if you cannoy modify this ThreadGroup.
+ /**
+ * Tell whether this ThreadGroup is a daemon group. A daemon group will
+ * be automatically destroyed when its last thread is stopped and
+ * its last thread group is destroyed.
+ *
+ * @return whether this ThreadGroup is a daemon group
*/
- public final void setDaemon (boolean daemon)
- {
- checkAccess();
- daemon_flag = daemon;
- }
-
- /** Tell whether this ThreadGroup is a daemon group. A daemon
- * group will be destroyed when its last thread is stopped and
- * its last thread group is destroyed.
- * @specnote The Java API docs indicate that the group is destroyed
- * when either of those happen, but that doesn't make
- * sense.
- * @return whether this ThreadGroup is a daemon group.
- */
public final boolean isDaemon()
{
return daemon_flag;
}
- /** Tell whether this ThreadGroup has been destroyed or not.
- * @return whether this ThreadGroup has been destroyed or not.
- */
+ /**
+ * Tell whether this ThreadGroup has been destroyed or not.
+ *
+ * @return whether this ThreadGroup has been destroyed or not
+ * @since 1.1
+ */
public synchronized boolean isDestroyed()
{
- return parent == null && this != root;
+ return groups == null;
}
- /** Check whether this ThreadGroup is an ancestor of the
- * specified ThreadGroup, or if they are the same.
- *
- * @param g the group to test on.
- * @return whether this ThreadGroup is a parent of the
- * specified group.
- */
+ /**
+ * Set whether this ThreadGroup is a daemon group. A daemon group will be
+ * destroyed when its last thread is stopped and its last thread group is
+ * destroyed. There may be a security check, <code>checkAccess</code>.
+ *
+ * @param daemon whether this ThreadGroup should be a daemon group
+ * @throws SecurityException if you cannot modify this ThreadGroup
+ * @see #checkAccess()
+ */
+ public final void setDaemon(boolean daemon)
+ {
+ checkAccess();
+ daemon_flag = daemon;
+ }
+
+ /**
+ * Set the maximum priority for Threads in this ThreadGroup. setMaxPriority
+ * can only be used to reduce the current maximum. If maxpri is greater
+ * than the current Maximum of the parent group, the current value is not
+ * changed. Otherwise, all groups which belong to this have their priority
+ * adjusted as well. Calling this does not affect threads already in this
+ * ThreadGroup. There may be a security check, <code>checkAccess</code>.
+ *
+ * @param maxpri the new maximum priority for this ThreadGroup
+ * @throws SecurityException if you cannot modify this ThreadGroup
+ * @see #getMaxPriority()
+ * @see #checkAccess()
+ */
+ public final synchronized void setMaxPriority(int maxpri)
+ {
+ checkAccess();
+ if (maxpri < Thread.MIN_PRIORITY || maxpri > Thread.MAX_PRIORITY)
+ return;
+ if (parent != null && maxpri > parent.maxpri)
+ maxpri = parent.maxpri;
+ this.maxpri = maxpri;
+ if (groups == null)
+ return;
+ int i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).setMaxPriority(maxpri);
+ }
+
+ /**
+ * Check whether this ThreadGroup is an ancestor of the specified
+ * ThreadGroup, or if they are the same.
+ *
+ * @param g the group to test on
+ * @return whether this ThreadGroup is a parent of the specified group
+ */
public final boolean parentOf(ThreadGroup tg)
{
while (tg != null)
@@ -205,423 +252,497 @@ public class ThreadGroup
return false;
}
- /** Return the total number of active threads in this ThreadGroup
- * and all its descendants.<P>
- *
- * This cannot return an exact number, since the status of threads
- * may change after they were counted. But it should be pretty
- * close.<P>
- *
- * @return the number of active threads in this ThreadGroup and
- * its descendants.
- * @specnote it isn't clear what the definition of an "Active" thread is.
- * Current JDKs regard a thread as active if has been
- * started and not finished. We implement this behaviour.
- * There is a JDC bug, <A HREF="http://developer.java.sun.com/developer/bugParade/bugs/4089701.html">
- * 4089701</A>, regarding this issue.
- *
- */
- public synchronized int activeCount()
+ /**
+ * Find out if the current Thread can modify this ThreadGroup. This passes
+ * the check on to <code>SecurityManager.checkAccess(this)</code>.
+ *
+ * @throws SecurityException if the current Thread cannot modify this
+ * ThreadGroup
+ * @see SecurityManager#checkAccess(ThreadGroup)
+ */
+ public final void checkAccess()
{
- int total = 0;
- for (int i = 0; i < threads.size(); ++i)
- {
- if (((Thread) threads.elementAt(i)).isAlive ())
- ++total;
- }
-
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup g = (ThreadGroup) groups.elementAt(i);
- total += g.activeCount();
- }
- return total;
+ // Bypass System.getSecurityManager, for bootstrap efficiency.
+ SecurityManager sm = Runtime.securityManager;
+ if (sm != null)
+ sm.checkAccess(this);
}
- /** Get the number of active groups in this ThreadGroup. This group
- * itself is not included in the count.
- * @specnote it is unclear what exactly constitutes an
- * active ThreadGroup. Currently we assume that
- * all sub-groups are active, per current JDKs.
- * @return the number of active groups in this ThreadGroup.
- */
- public synchronized int activeGroupCount()
+ /**
+ * Return an estimate of the total number of active threads in this
+ * ThreadGroup and all its descendants. This cannot return an exact number,
+ * since the status of threads may change after they were counted; but it
+ * should be pretty close. Based on a JDC bug,
+ * <a href="http://developer.java.sun.com/developer/bugParade/bugs/4089701.html">
+ * 4089701</a>, we take active to mean isAlive().
+ *
+ * @return count of active threads in this ThreadGroup and its descendants
+ */
+ public int activeCount()
{
- int total = groups.size();
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup g = (ThreadGroup) groups.elementAt(i);
- total += g.activeGroupCount();
- }
+ int total = 0;
+ if (groups == null)
+ return total;
+ int i = threads.size();
+ while (--i >= 0)
+ if (((Thread) threads.get(i)).isAlive())
+ total++;
+ i = groups.size();
+ while (--i >= 0)
+ total += ((ThreadGroup) groups.get(i)).activeCount();
return total;
}
- /** Copy all of the active Threads from this ThreadGroup and
- * its descendants into the specified array. If the array is
- * not big enough to hold all the Threads, extra Threads will
- * simply not be copied.
- *
- * @param threads the array to put the threads into.
- * @return the number of threads put into the array.
- */
- public int enumerate(Thread[] threads)
- {
- return enumerate(threads, 0, true);
- }
-
- /** Copy all of the active Threads from this ThreadGroup and,
- * if desired, from its descendants, into the specified array.
- * If the array is not big enough to hold all the Threads,
- * extra Threads will simply not be copied.
- *
- * @param threads the array to put the threads into.
- * @param useDescendants whether to count Threads in this
- * ThreadGroup's descendants or not.
- * @return the number of threads put into the array.
- */
- public int enumerate(Thread[] threads, boolean useDescendants)
- {
- return enumerate(threads, 0, useDescendants);
- }
-
- // This actually implements enumerate.
- private synchronized int enumerate(Thread[] list, int next_index,
- boolean recurse)
- {
- Enumeration e = threads.elements();
- while (e.hasMoreElements() && next_index < list.length)
- {
- Thread t = (Thread) e.nextElement();
- if (t.isAlive ())
- list[next_index++] = t;
- }
- if (recurse && next_index != list.length)
- {
- e = groups.elements();
- while (e.hasMoreElements() && next_index < list.length)
- {
- ThreadGroup g = (ThreadGroup) e.nextElement();
- next_index = g.enumerate(list, next_index, true);
- }
- }
- return next_index;
- }
-
- /** Copy all active ThreadGroups that are descendants of this
- * ThreadGroup into the specified array. If the array is not
- * large enough to hold all active ThreadGroups, extra
- * ThreadGroups simply will not be copied.
- *
- * @param groups the array to put the ThreadGroups into.
- * @return the number of ThreadGroups copied into the array.
- */
- public int enumerate(ThreadGroup[] groups)
- {
- return enumerate(groups, 0, true);
- }
-
- /** Copy all active ThreadGroups that are children of this
- * ThreadGroup into the specified array, and if desired, also
- * copy all active descendants into the array. If the array
- * is not large enough to hold all active ThreadGroups, extra
- * ThreadGroups simply will not be copied.
- *
- * @param groups the array to put the ThreadGroups into.
- * @param recurse whether to include all descendants
- * of this ThreadGroup's children in determining
- * activeness.
- * @return the number of ThreadGroups copied into the array.
- */
- public int enumerate(ThreadGroup[] groups, boolean recurse)
+ /**
+ * Copy all of the active Threads from this ThreadGroup and its descendants
+ * into the specified array. If the array is not big enough to hold all
+ * the Threads, extra Threads will simply not be copied. There may be a
+ * security check, <code>checkAccess</code>.
+ *
+ * @param array the array to put the threads into
+ * @return the number of threads put into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if array is null
+ * @throws ArrayStoreException if a thread does not fit in the array
+ * @see #activeCount()
+ * @see #checkAccess()
+ * @see #enumerate(Thread[], boolean)
+ */
+ public int enumerate(Thread[] array)
+ {
+ return enumerate(array, 0, true);
+ }
+
+ /**
+ * Copy all of the active Threads from this ThreadGroup and, if desired,
+ * from its descendants, into the specified array. If the array is not big
+ * enough to hold all the Threads, extra Threads will simply not be copied.
+ * There may be a security check, <code>checkAccess</code>.
+ *
+ * @param array the array to put the threads into
+ * @param recurse whether to recurse into descendent ThreadGroups
+ * @return the number of threads put into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if array is null
+ * @throws ArrayStoreException if a thread does not fit in the array
+ * @see #activeCount()
+ * @see #checkAccess()
+ */
+ public int enumerate(Thread[] array, boolean recurse)
{
- return enumerate(groups, 0, recurse);
+ return enumerate(array, 0, recurse);
}
- // This actually implements enumerate.
- private synchronized int enumerate (ThreadGroup[] list, int next_index,
- boolean recurse)
+ /**
+ * Get the number of active groups in this ThreadGroup. This group itself
+ * is not included in the count. A sub-group is active if it has not been
+ * destroyed. This cannot return an exact number, since the status of
+ * threads may change after they were counted; but it should be pretty close.
+ *
+ * @return the number of active groups in this ThreadGroup
+ */
+ public int activeGroupCount()
{
- Enumeration e = groups.elements();
- while (e.hasMoreElements() && next_index < list.length)
- {
- ThreadGroup g = (ThreadGroup) e.nextElement();
- list[next_index++] = g;
- if (recurse && next_index != list.length)
- next_index = g.enumerate(list, next_index, true);
- }
- return next_index;
+ if (groups == null)
+ return 0;
+ int total = groups.size();
+ int i = total;
+ while (--i >= 0)
+ total += ((ThreadGroup) groups.get(i)).activeGroupCount();
+ return total;
}
- /** Interrupt all Threads in this ThreadGroup and its sub-groups.
- * @exception SecurityException if you cannot modify this
- * ThreadGroup or any of its Threads or children
- * ThreadGroups.
- * @since JDK1.2
- */
- public final synchronized void interrupt()
+ /**
+ * Copy all active ThreadGroups that are descendants of this ThreadGroup
+ * into the specified array. If the array is not large enough to hold all
+ * active ThreadGroups, extra ThreadGroups simply will not be copied. There
+ * may be a security check, <code>checkAccess</code>.
+ *
+ * @param array the array to put the ThreadGroups into
+ * @return the number of ThreadGroups copied into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if array is null
+ * @throws ArrayStoreException if a group does not fit in the array
+ * @see #activeCount()
+ * @see #checkAccess()
+ * @see #enumerate(ThreadGroup[], boolean)
+ */
+ public int enumerate(ThreadGroup[] array)
+ {
+ return enumerate(array, 0, true);
+ }
+
+ /**
+ * Copy all active ThreadGroups that are children of this ThreadGroup into
+ * the specified array, and if desired, also all descendents. If the array
+ * is not large enough to hold all active ThreadGroups, extra ThreadGroups
+ * simply will not be copied. There may be a security check,
+ * <code>checkAccess</code>.
+ *
+ * @param array the array to put the ThreadGroups into
+ * @param recurse whether to recurse into descendent ThreadGroups
+ * @return the number of ThreadGroups copied into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if array is null
+ * @throws ArrayStoreException if a group does not fit in the array
+ * @see #activeCount()
+ * @see #checkAccess()
+ */
+ public int enumerate(ThreadGroup[] array, boolean recurse)
+ {
+ return enumerate(array, 0, recurse);
+ }
+
+ /**
+ * Stop all Threads in this ThreadGroup and its descendants.
+ *
+ * <p>This is inherently unsafe, as it can interrupt synchronized blocks and
+ * leave data in bad states. Hence, there is a security check:
+ * <code>checkAccess()</code>, followed by further checks on each thread
+ * being stopped.
+ *
+ * @throws SecurityException if permission is denied
+ * @see #checkAccess()
+ * @see Thread#stop(Throwable)
+ * @deprecated unsafe operation, try not to use
+ */
+ public final synchronized void stop()
{
checkAccess();
- for (int i=0; i < threads.size(); i++)
- {
- Thread t = (Thread) threads.elementAt(i);
- t.interrupt();
- }
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.interrupt();
- }
- }
-
- /** Stop all Threads in this ThreadGroup and its descendants.
- * @exception SecurityException if you cannot modify this
- * ThreadGroup or any of its Threads or children
- * ThreadGroups.
- * @deprecated This method calls Thread.stop(), which is dangerous.
- */
- public final synchronized void stop()
+ if (groups == null)
+ return;
+ int i = threads.size();
+ while (--i >= 0)
+ ((Thread) threads.get(i)).stop();
+ i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).stop();
+ }
+
+ /**
+ * Interrupt all Threads in this ThreadGroup and its sub-groups. There may
+ * be a security check, <code>checkAccess</code>.
+ *
+ * @throws SecurityException if permission is denied
+ * @see #checkAccess()
+ * @see Thread#interrupt()
+ * @since 1.2
+ */
+ public final synchronized void interrupt()
{
checkAccess();
- for (int i=0; i<threads.size(); i++)
- {
- Thread t = (Thread) threads.elementAt(i);
- t.stop();
- }
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.stop();
- }
- }
-
- /** Suspend all Threads in this ThreadGroup and its descendants.
- * @exception SecurityException if you cannot modify this
- * ThreadGroup or any of its Threads or children
- * ThreadGroups.
- * @deprecated This method calls Thread.suspend(), which is dangerous.
- */
+ if (groups == null)
+ return;
+ int i = threads.size();
+ while (--i >= 0)
+ ((Thread) threads.get(i)).interrupt();
+ i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).interrupt();
+ }
+
+ /**
+ * Suspend all Threads in this ThreadGroup and its descendants.
+ *
+ * <p>This is inherently unsafe, as suspended threads still hold locks,
+ * which can lead to deadlock. Hence, there is a security check:
+ * <code>checkAccess()</code>, followed by further checks on each thread
+ * being suspended.
+ *
+ * @throws SecurityException if permission is denied
+ * @see #checkAccess()
+ * @see Thread#suspend()
+ * @deprecated unsafe operation, try not to use
+ */
public final synchronized void suspend()
{
checkAccess();
- for (int i=0; i<threads.size(); i++)
- {
- Thread t = (Thread) threads.elementAt(i);
- t.suspend();
- }
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.suspend();
- }
- }
-
- /** Resume all Threads in this ThreadGroup and its descendants.
- * @exception SecurityException if you cannot modify this
- * ThreadGroup or any of its Threads or children
- * ThreadGroups.
- * @deprecated This method relies on Thread.suspend(), which is dangerous.
- */
+ if (groups == null)
+ return;
+ int i = threads.size();
+ while (--i >= 0)
+ ((Thread) threads.get(i)).suspend();
+ i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).suspend();
+ }
+
+ /**
+ * Resume all suspended Threads in this ThreadGroup and its descendants.
+ * To mirror suspend(), there is a security check:
+ * <code>checkAccess()</code>, followed by further checks on each thread
+ * being resumed.
+ *
+ * @throws SecurityException if permission is denied
+ * @see #checkAccess()
+ * @see Thread#suspend()
+ * @deprecated pointless, since suspend is deprecated
+ */
public final synchronized void resume()
{
checkAccess();
- for (int i=0; i < threads.size(); i++)
- {
- Thread t = (Thread) threads.elementAt(i);
- t.resume();
- }
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.resume();
- }
- }
-
- // This is a helper that is used to implement the destroy method.
- private synchronized void checkDestroy ()
- {
- if (! threads.isEmpty())
- throw new IllegalThreadStateException ("ThreadGroup has threads");
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.checkDestroy();
- }
- }
-
- /** Destroy this ThreadGroup. There can be no Threads in it,
- * and none of its descendants (sub-groups) may have Threads in them.
- * All its descendants will be destroyed as well.
- * @exception IllegalThreadStateException if the ThreadGroup or
- * its descendants have Threads remaining in them, or
- * if the ThreadGroup in question is already destroyed.
- * @exception SecurityException if you cannot modify this
- * ThreadGroup or any of its descendants.
- */
+ if (groups == null)
+ return;
+ int i = threads.size();
+ while (--i >= 0)
+ ((Thread) threads.get(i)).resume();
+ i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).resume();
+ }
+
+ /**
+ * Destroy this ThreadGroup. The group must be empty, meaning that all
+ * threads and sub-groups have completed execution. Daemon groups are
+ * destroyed automatically. There may be a security check,
+ * <code>checkAccess</code>.
+ *
+ * @throws IllegalThreadStateException if the ThreadGroup is not empty, or
+ * was previously destroyed
+ * @throws SecurityException if permission is denied
+ * @see #checkAccess()
+ */
public final synchronized void destroy()
{
checkAccess();
- if (isDestroyed())
- throw new IllegalThreadStateException("Already destroyed.");
- checkDestroy ();
+ if (! threads.isEmpty() || groups == null)
+ throw new IllegalThreadStateException();
+ int i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).destroy();
+ groups = null;
if (parent != null)
parent.removeGroup(this);
- parent = null;
-
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.destroy();
- }
}
-
- /** Print out information about this ThreadGroup to System.out.
- */
+
+ /**
+ * Print out information about this ThreadGroup to System.out. This is
+ * meant for debugging purposes. <b>WARNING:</b> This method is not secure,
+ * and can print the name of threads to standard out even when you cannot
+ * otherwise get at such threads.
+ */
public void list()
{
list("");
}
- private synchronized void list(String indentation)
- {
- System.out.print(indentation);
- System.out.println(toString ());
- String sub = indentation + " ";
- for (int i=0; i < threads.size(); i++)
- {
- Thread t = (Thread) threads.elementAt(i);
- System.out.print(sub);
- System.out.println(t.toString());
- }
- for (int i=0; i < groups.size(); i++)
- {
- ThreadGroup tg = (ThreadGroup) groups.elementAt(i);
- tg.list(sub);
- }
- }
-
- /** When a Thread in this ThreadGroup does not catch an exception,
- * this method of the ThreadGroup is called.<P>
- *
- * ThreadGroup's implementation does the following:<BR>
- * <OL>
- * <LI>If there is a parent ThreadGroup, call uncaughtException()
- * in the parent.</LI>
- * <LI>If the Throwable passed is a ThreadDeath, don't do
- * anything.</LI>
- * <LI>Otherwise, call <CODE>exception.printStackTrace().</CODE></LI>
- * </OL>
- *
- * @param thread the thread that exited.
- * @param exception the uncaught exception.
- */
+ /**
+ * When a Thread in this ThreadGroup does not catch an exception, the
+ * virtual machine calls this method. The default implementation simply
+ * passes the call to the parent; then in top ThreadGroup, it will
+ * ignore ThreadDeath and print the stack trace of any other throwable.
+ * Override this method if you want to handle the exception in a different
+ * manner.
+ *
+ * @param thread the thread that exited
+ * @param exception the uncaught exception
+ * @throws NullPointerException if t is null
+ * @see ThreadDeath
+ * @see System#err
+ * @see Throwable#printStackTrace()
+ */
public void uncaughtException(Thread thread, Throwable t)
{
if (parent != null)
- parent.uncaughtException (thread, t);
+ parent.uncaughtException(thread, t);
else if (! (t instanceof ThreadDeath))
{
- if (thread != null)
- System.err.print ("Exception in thread \""
- + thread.getName() + "\" ");
- try
- {
- t.printStackTrace(System.err);
- }
- catch (Throwable x)
- {
- // This means that something is badly screwed up with the runtime,
- // or perhaps someone is messing with the SecurityManager. In any
- // case, try to deal with it gracefully.
- System.err.println(t);
- System.err.println("*** Got " + x.toString() +
- " while trying to print stack trace");
- }
- had_uncaught_exception = true;
+ if (t == null)
+ throw new NullPointerException();
+ had_uncaught_exception = true;
+ try
+ {
+ if (thread != null)
+ System.err.print("Exception in thread \"" + thread.name + "\" ");
+ t.printStackTrace(System.err);
+ }
+ catch (Throwable x)
+ {
+ // This means that something is badly screwed up with the runtime,
+ // or perhaps someone overloaded the Throwable.printStackTrace to
+ // die. In any case, try to deal with it gracefully.
+ try
+ {
+ System.err.println(t);
+ System.err.println("*** Got " + x
+ + " while trying to print stack trace.");
+ }
+ catch (Throwable x2)
+ {
+ // Here, someone may have overloaded t.toString() or
+ // x.toString() to die. Give up all hope; we can't even chain
+ // the exception, because the chain would likewise die.
+ System.err.println("*** Catastrophic failure while handling "
+ + "uncaught exception.");
+ throw new InternalError();
+ }
+ }
}
}
- /** Tell the VM whether it may suspend Threads in low memory
- * situations.
- * @deprecated This method is unimplemented, because it would rely on
- * suspend(), which is deprecated. There is no way for a Java
- * program to determine whether this has any effect whatsoever,
- * so we don't need it.
- * @return false
- */
+ /**
+ * Originally intended to tell the VM whether it may suspend Threads in
+ * low memory situations, this method was never implemented by Sun, and
+ * is hence a no-op.
+ *
+ * @param allow whether to allow low-memory thread suspension; ignored
+ * @return false
+ * @since 1.1
+ * @deprecated pointless, since suspend is deprecated
+ */
public boolean allowThreadSuspension(boolean allow)
{
return false;
}
- /** Get a human-readable representation of this ThreadGroup.
- * @return a String representing this ThreadGroup.
- * @specnote Language Spec and Class Libraries book disagree a bit here.
- * We follow the Spec, but add "ThreadGroup" per the book. We
- * include "java.lang" based on the list() example in the Class
- * Libraries book.
- */
- public String toString ()
+ /**
+ * Return a human-readable String representing this ThreadGroup. The format
+ * of the string is:<br>
+ * <code>getClass().getName() + "[name=" + getName() + ",maxpri="
+ * + getMaxPriority() + ']'</code>.
+ *
+ * @return a human-readable String representing this ThreadGroup
+ */
+ public String toString()
+ {
+ return getClass().getName() + "[name=" + name + ",maxpri=" + maxpri + ']';
+ }
+
+ /**
+ * Implements enumerate.
+ *
+ * @param list the array to put the threads into
+ * @param next the next open slot in the array
+ * @param recurse whether to recurse into descendent ThreadGroups
+ * @return the number of threads put into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if list is null
+ * @throws ArrayStoreException if a thread does not fit in the array
+ * @see #enumerate(Thread[])
+ * @see #enumerate(Thread[], boolean)
+ */
+ private int enumerate(Thread[] list, int next, boolean recurse)
{
- return "java.lang.ThreadGroup[name=" + name +
- ",maxpri=" + maxpri + "]";
- }
-
- /** Find out if the current Thread can modify this ThreadGroup.
- * Calls the current SecurityManager's checkAccess() method to
- * find out. If there is none, it assumes everything's OK.
- * @exception SecurityException if the current Thread cannot
- * modify this ThreadGroup.
- */
- public final void checkAccess()
+ checkAccess();
+ if (groups == null)
+ return next;
+ int i = threads.size();
+ while (--i >= 0 && next < list.length)
+ {
+ Thread t = (Thread) threads.get(i);
+ if (t.isAlive())
+ list[next++] = t;
+ }
+ if (recurse)
+ {
+ i = groups.size();
+ while (--i >= 0 && next < list.length)
+ {
+ ThreadGroup g = (ThreadGroup) groups.get(i);
+ next = g.enumerate(list, next, true);
+ }
+ }
+ return next;
+ }
+
+ /**
+ * Implements enumerate.
+ *
+ * @param list the array to put the groups into
+ * @param next the next open slot in the array
+ * @param recurse whether to recurse into descendent ThreadGroups
+ * @return the number of groups put into the array
+ * @throws SecurityException if permission was denied
+ * @throws NullPointerException if list is null
+ * @throws ArrayStoreException if a group does not fit in the array
+ * @see #enumerate(ThreadGroup[])
+ * @see #enumerate(ThreadGroup[], boolean)
+ */
+ private int enumerate(ThreadGroup[] list, int next, boolean recurse)
{
- SecurityManager sm = System.getSecurityManager();
- if (sm != null)
- sm.checkAccess(this);
+ checkAccess();
+ if (groups == null)
+ return next;
+ int i = groups.size();
+ while (--i >= 0 && next < list.length)
+ {
+ ThreadGroup g = (ThreadGroup) groups.get(i);
+ list[next++] = g;
+ if (recurse && next != list.length)
+ next = g.enumerate(list, next, true);
+ }
+ return next;
}
- // This is called to add a Thread to our internal list.
+ /**
+ * Implements list.
+ *
+ * @param indentation the current level of indentation
+ * @see #list()
+ */
+ private void list(String indentation)
+ {
+ if (groups == null)
+ return;
+ System.out.print(indentation + this);
+ indentation += " ";
+ int i = threads.size();
+ while (--i >= 0)
+ System.out.println(indentation + threads.get(i));
+ i = groups.size();
+ while (--i >= 0)
+ ((ThreadGroup) groups.get(i)).list(indentation);
+ }
+
+ /**
+ * Add a thread to the group. Called by Thread constructors.
+ *
+ * @param t the thread to add, non-null
+ * @throws IllegalThreadStateException if the group is destroyed
+ */
final synchronized void addThread(Thread t)
{
- if (isDestroyed())
- throw new IllegalThreadStateException ("ThreadGroup is destroyed");
-
- threads.addElement(t);
+ if (groups == null)
+ throw new IllegalThreadStateException("ThreadGroup is destroyed");
+ threads.add(t);
}
- // This is called to remove a Thread from our internal list.
+ /**
+ * Called by the VM to remove a thread that has died.
+ *
+ * @param t the thread to remove, non-null
+ * @XXX A ThreadListener to call this might be nice.
+ */
final synchronized void removeThread(Thread t)
{
- if (isDestroyed())
- throw new IllegalThreadStateException ();
-
- threads.removeElement(t);
+ if (groups == null)
+ return;
+ threads.remove(t);
// Daemon groups are automatically destroyed when all their threads die.
if (daemon_flag && groups.size() == 0 && threads.size() == 0)
{
- // We inline destroy to avoid the access check.
- if (parent != null)
- parent.removeGroup(this);
- parent = null;
+ // We inline destroy to avoid the access check.
+ groups = null;
+ if (parent != null)
+ parent.removeGroup(this);
}
}
- // This is called to add a ThreadGroup to our internal list.
- final synchronized void addGroup(ThreadGroup g)
- {
- groups.addElement(g);
- }
-
- // This is called to remove a ThreadGroup from our internal list.
+ /**
+ * Called when a group is destroyed, to remove it from its parent.
+ *
+ * @param g the destroyed group, non-null
+ */
final synchronized void removeGroup(ThreadGroup g)
{
- groups.removeElement(g);
+ groups.remove(g);
// Daemon groups are automatically destroyed when all their threads die.
if (daemon_flag && groups.size() == 0 && threads.size() == 0)
{
- // We inline destroy to avoid the access check.
- if (parent != null)
- parent.removeGroup(this);
- parent = null;
+ // We inline destroy to avoid the access check.
+ groups = null;
+ if (parent != null)
+ parent.removeGroup(this);
}
}
-}
+} // class ThreadGroup