ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/ThreadLocalTest.java

Comparing jsr166/src/test/tck/ThreadLocalTest.java (file contents):
Revision 1.4 by dl, Sat Dec 27 19:26:44 2003 UTC vs.
Revision 1.5 by dl, Sat Jan 10 20:37:20 2004 UTC

#	Line 18 | Line 18 | public class ThreadLocalTest extends JSR
18		return new TestSuite(ThreadLocalTest.class);
19		}
20
21	<	static ThreadLocal tl = new ThreadLocal() {
22	<	public Object initialValue() {
23	<	return new Integer(1);
21	>	static ThreadLocal<Integer> tl = new ThreadLocal<Integer>() {
22	>	public Integer initialValue() {
23	>	return one;
24	>	}
25	>	};
26	>
27	>	static InheritableThreadLocal<Integer> itl =
28	>	new InheritableThreadLocal<Integer>() {
29	>	protected Integer initialValue() {
30	>	return zero;
31	>	}
32	>
33	>	protected Integer childValue(Integer parentValue) {
34	>	return new Integer(parentValue.intValue() + 1);
35		}
36		};
37
27	–
38		/**
39		* remove causes next access to return initial value
40		*/
41		public void testRemove() {
32	–	Integer one = new Integer(1);
33	–	Integer two = new Integer(2);
42		assertEquals(tl.get(), one);
43		tl.set(two);
44		assertEquals(tl.get(), two);
45		tl.remove();
46		assertEquals(tl.get(), one);
47		}
48	+
49	+	/**
50	+	* remove in InheritableThreadLocal causes next access to return
51	+	* initial value
52	+	*/
53	+	public void testRemoveITL() {
54	+	assertEquals(itl.get(), zero);
55	+	itl.set(two);
56	+	assertEquals(itl.get(), two);
57	+	itl.remove();
58	+	assertEquals(itl.get(), zero);
59	+	}
60	+
61	+	private class ITLThread extends Thread {
62	+	final int[] x;
63	+	ITLThread(int[] array) { x = array; }
64	+	public void run() {
65	+	Thread child = null;
66	+	if (itl.get().intValue() < x.length - 1) {
67	+	child = new ITLThread(x);
68	+	child.start();
69	+	}
70	+	Thread.currentThread().yield();
71	+
72	+	int threadId = itl.get().intValue();
73	+	for (int j = 0; j < threadId; j++) {
74	+	x[threadId]++;
75	+	Thread.currentThread().yield();
76	+	}
77	+
78	+	if (child != null) { // Wait for child (if any)
79	+	try {
80	+	child.join();
81	+	} catch(InterruptedException e) {
82	+	threadUnexpectedException();
83	+	}
84	+	}
85	+	}
86	+	}
87	+
88	+	/**
89	+	* InheritableThreadLocal propagates generic values.
90	+	*/
91	+	public void testGenericITL() {
92	+	final int threadCount = 10;
93	+	final int x[] = new int[threadCount];
94	+	Thread progenitor = new ITLThread(x);
95	+	try {
96	+	progenitor.start();
97	+	progenitor.join();
98	+	for(int i = 0; i < threadCount; i++) {
99	+	assertEquals(i, x[i]);
100	+	}
101	+	} catch(InterruptedException e) {
102	+	unexpectedException();
103	+	}
104	+	}
105		}
106

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines