This is the mail archive of the java-patches@gcc.gnu.org mailing list for the Java project.


Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]

Re: New classes from Classpath


Hi,

On Tue, Oct 02, 2001 at 08:45:34AM -0600, Tom Tromey wrote:
> >>>>> "Mark" == Mark Wielaard <mark@klomp.org> writes:
> 
> Mark> I think you are right and you might have found one of the
> Mark> problems that I was having with some small tests that I was
> Mark> running. There is also another problem since one test throws a
> Mark> ConcurrentModificationExceptions from newChildThread(). Seems
> Mark> that I have a thinko somewhere in the code but I cannot find
> Mark> it. Will debug some more tomorrow.
> 
> Ok, thanks.  You can check in all the other parts of the patch now if
> you want, or you can wait if you'd prefer that.

I already checked in the other stuff. I have found the bug in
InheritableThreadLocal (see the Classpath mailinglist). I also
followed your suggestion and moved the call to newChildThread() up.
So I am checking this in.

2001-10-02  Mark Wielaard  <mark@klomp.org>

	* Makefile.am (core_java_source_files): add InheritableThreadLocal
	* Makefile.in: regenerate
	* gcj/javaprims.h: ditto
	* java/lang/InheritableThreadLocal.java: new class from Classpath
	* java/lang/Thread.java Thread (Thread, ThreadGroup, Runnable, String):
	call InheritableThreadLocal.newChildThread()

Cheers,

Mark
-- 
Stuff to read:
    <http://www.toad.com/gnu/whatswrong.html>
  What's Wrong with Copy Protection, by John Gilmore
Index: Makefile.am
===================================================================
RCS file: /cvs/gcc/gcc/libjava/Makefile.am,v
retrieving revision 1.173
diff -u -r1.173 Makefile.am
--- Makefile.am	2001/10/02 20:59:30	1.173
+++ Makefile.am	2001/10/02 22:37:04
@@ -937,6 +937,7 @@
 java/lang/IllegalThreadStateException.java \
 java/lang/IncompatibleClassChangeError.java \
 java/lang/IndexOutOfBoundsException.java \
+java/lang/InheritableThreadLocal.java \
 java/lang/InstantiationError.java \
 java/lang/InstantiationException.java \
 java/lang/Integer.java \
Index: Makefile.in
===================================================================
RCS file: /cvs/gcc/gcc/libjava/Makefile.in,v
retrieving revision 1.184
diff -u -r1.184 Makefile.in
--- Makefile.in	2001/10/02 20:59:30	1.184
+++ Makefile.in	2001/10/02 22:37:06
@@ -668,6 +668,7 @@
 java/lang/IllegalThreadStateException.java \
 java/lang/IncompatibleClassChangeError.java \
 java/lang/IndexOutOfBoundsException.java \
+java/lang/InheritableThreadLocal.java \
 java/lang/InstantiationError.java \
 java/lang/InstantiationException.java \
 java/lang/Integer.java \
@@ -1793,6 +1794,7 @@
 .deps/java/lang/IllegalThreadStateException.P \
 .deps/java/lang/IncompatibleClassChangeError.P \
 .deps/java/lang/IndexOutOfBoundsException.P \
+.deps/java/lang/InheritableThreadLocal.P \
 .deps/java/lang/InstantiationError.P \
 .deps/java/lang/InstantiationException.P .deps/java/lang/Integer.P \
 .deps/java/lang/InternalError.P .deps/java/lang/InterruptedException.P \
Index: gcj/javaprims.h
===================================================================
RCS file: /cvs/gcc/gcc/libjava/gcj/javaprims.h,v
retrieving revision 1.29
diff -u -r1.29 javaprims.h
--- javaprims.h	2001/10/02 20:59:30	1.29
+++ javaprims.h	2001/10/02 22:37:06
@@ -162,6 +162,7 @@
       class IllegalThreadStateException;
       class IncompatibleClassChangeError;
       class IndexOutOfBoundsException;
+      class InheritableThreadLocal;
       class InstantiationError;
       class InstantiationException;
       class Integer;
Index: java/lang/InheritableThreadLocal.java
===================================================================
RCS file: InheritableThreadLocal.java
diff -N InheritableThreadLocal.java
--- /dev/null	Tue May  5 13:32:27 1998
+++ InheritableThreadLocal.java	Tue Oct  2 15:37:06 2001
@@ -0,0 +1,167 @@
+/* java.lang.InheritableThreadLocal
+   Copyright (C) 2000, 2001 Free Software Foundation, Inc.
+
+This file is part of GNU Classpath.
+
+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
+General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with GNU Classpath; see the file COPYING.  If not, write to the
+Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
+02111-1307 USA.
+
+As a special exception, if you link this library with other files to
+produce an executable, this library does not by itself cause the
+resulting executable to be covered by the GNU General Public License.
+This exception does not however invalidate any other reasons why the
+executable file might be covered by the GNU General Public License. */
+
+package java.lang;
+
+import java.util.Iterator;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.Set;
+import java.util.WeakHashMap;
+
+/**
+ * ThreadLocal whose value is inherited by child Threads.
+ * The value of the InheritableThreadLocal associated with the (parent) Thread
+ * on the moment that it creates a new (child) Thread is set as the value that
+ * is associated with the new (child) Thread.
+ * <p>
+ * It is possible to make the value associated with the child Thread a function
+ * of the value that is associated with the parent Thread by overriding the
+ * <code>childValue()</code> method.
+ *
+ * @since 1.2
+ * @author Mark Wielaard (mark@klomp.org)
+ */
+public class InheritableThreadLocal extends ThreadLocal {
+	
+	/**
+	 * Maps Threads to a Set of InheritableThreadLocals
+	 * (the heritage of that Thread).
+	 * Uses a WeakHashMap so if the Thread is garbage collected the reference
+	 * to that Set disappears.
+	 * Both <code>AddToHeritage</code> access and modify it so they have to
+	 * synchronize on the threadMap when they do.
+	 */
+	private static Map threadMap = new WeakHashMap();
+	
+	/**
+	 * Creates a new InheritableThreadLocal that has no values associated
+	 * with it yet.
+	 */
+	public InheritableThreadLocal() {
+		super();
+	}
+	
+	/**
+	 * Determines the value associated with a newly created child Thread
+	 * as a function of the value associated with the currently executing
+	 * (parent) Thread.
+	 * <p>
+	 * The default implementation just returns the parentValue.
+	 */
+	protected Object childValue(Object parentValue) {
+		return parentValue;
+	}
+	
+	/**
+	 * Adds this <code>InheritableThreadLocal</code> to the heritage of the
+	 * current Thread and returns the value of the <code>ThreadLocal</code>
+	 * for the Thread. The value will be either the last value that the
+	 * current Thread has set, or the childValue of the last value that the
+	 * parent Thread set before the current Thread was created, or the
+	 * initialValue of the <code>ThreadLocal</code>.
+	 *
+	 * @see ThreadLocal#get()
+	 */
+	public Object get() {
+		addToHeritage(); 
+		return super.get();
+	}
+	
+	/**
+	 * Adds this <code>InheritableThreadLocal</code> to the heritage of the
+	 * current Thread and sets the value of the <code>ThreadLocal</code>
+	 * for the Thread.
+	 *
+	 * @see ThreadLocal#set(Object)
+	 */
+	public void set(Object value) {
+		addToHeritage();
+		super.set(value);
+	}
+	
+	/**
+	 * Adds this <code>InheritableThreadLocal</code> to the heritage
+	 * of the current Thread.
+	 */
+	private void addToHeritage() {
+		Thread currentThread = Thread.currentThread();
+		Set heritage;
+		synchronized(threadMap) {
+			heritage = (Set)threadMap.get(currentThread);
+		}
+		// Note that we don't have to synchronize on the heritage Set
+		// since only this Thread (or the parent Thread when creating
+		// the heritage) ever modifies it.
+		if (heritage == null) {
+			heritage = new HashSet();
+			synchronized(threadMap) {
+				threadMap.put(currentThread, heritage);
+			}
+		}
+		if (!heritage.contains(this)) {
+			heritage.add(this);
+		}
+	}
+	
+	/**
+	 * Generates the childValues of all <code>InheritableThreadLocal</code>s
+	 * that are in the heritage of the current Thread for the newly created
+	 * childThread.
+	 * Should be called from the contructor of java.lang.Thread.
+	 */
+	static void newChildThread(Thread childThread) {
+		// The currentThread is the parent of the new thread
+		Thread parentThread = Thread.currentThread();
+		
+		// Inherit all the InheritableThreadLocals of the parent thread
+		Set heritage;
+		synchronized(threadMap) {
+			heritage = (Set)threadMap.get(parentThread);
+		}
+		// Note that we don't have to synchronize on the heritage Set
+		// since only this Thread (or the parent Thread when creating
+		// the heritage) ever modifies it.
+		if (heritage != null) {
+			synchronized(threadMap) {
+				threadMap.put(childThread, new HashSet(heritage));
+			}
+			// And constructs all the new child values
+			// (has to be done now that we are executing in the parentThread)
+			Iterator it = heritage.iterator();
+			while (it.hasNext()) {
+				InheritableThreadLocal local =
+					(InheritableThreadLocal) it.next();
+				// Note that the parentValue cannot be null
+				// If it was it would not be in the heritage
+				Object parentValue = local.get(parentThread).getValue();
+				Object childValue = local.childValue(parentValue);
+				ThreadLocal.Value v = new ThreadLocal.Value(childValue);
+				local.set(childThread, v);
+			}
+		}
+	}
+}
Index: java/lang/Thread.java
===================================================================
RCS file: /cvs/gcc/gcc/libjava/java/lang/Thread.java,v
retrieving revision 1.19
diff -u -r1.19 Thread.java
--- Thread.java	2001/08/26 11:30:09	1.19
+++ Thread.java	2001/10/02 22:37:07
@@ -247,6 +247,7 @@
 	int pri = current.getPriority();
 	priority = (gmax < pri ? gmax : pri);
 	context_class_loader = current.context_class_loader;
+	InheritableThreadLocal.newChildThread(this);
       }
     else
       {

Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]