ViewVC Help

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

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

Comparing jsr166/src/test/tck/LockSupportTest.java (file contents):
Revision 1.5 by dl, Sat Dec 27 19:26:43 2003 UTC vs.
Revision 1.14 by jsr166, Wed Aug 25 00:07:03 2010 UTC

#	Line 2 | Line 2
2		* Written by Doug Lea with assistance from members of JCP JSR-166
3		* Expert Group and released to the public domain, as explained at
4		* http://creativecommons.org/licenses/publicdomain
5	<	* Other contributors include Andrew Wright, Jeffrey Hayes,
6	<	* Pat Fisher, Mike Judd.
5	>	* Other contributors include Andrew Wright, Jeffrey Hayes,
6	>	* Pat Fisher, Mike Judd.
7		*/
8
9		import junit.framework.*;
#	Line 11 | Line 11 | import java.util.*;
11		import java.util.concurrent.*;
12		import java.util.concurrent.locks.*;
13
14	<	public class LockSupportTest extends JSR166TestCase{
14	>	public class LockSupportTest extends JSR166TestCase {
15		public static void main(String[] args) {
16	<	junit.textui.TestRunner.run (suite());
16	>	junit.textui.TestRunner.run(suite());
17		}
18		public static Test suite() {
19	<	return new TestSuite(LockSupportTest.class);
19	>	return new TestSuite(LockSupportTest.class);
20		}
21
22		/**
23	<	* park is released by unpark occuring after park
23	>	* park is released by unpark occurring after park
24		*/
25	<	public void testPark() {
26	<	Thread t = new Thread(new Runnable() {
27	<	public void run() {
28	<	try {
29	<	LockSupport.park();
30	<	} catch(Exception e){
31	<	threadUnexpectedException();
32	<	}
33	<	}
34	<	});
35	<	try {
36	<	t.start();
37	<	Thread.sleep(SHORT_DELAY_MS);
38	<	LockSupport.unpark(t);
39	<	t.join();
40	<	}
41	<	catch(Exception e) {
42	<	unexpectedException();
43	<	}
44	<	}
45	<
46	<	/**
47	<	* park is released by unpark occuring before park
48	<	*/
49	<	public void testPark2() {
50	<	Thread t = new Thread(new Runnable() {
51	<	public void run() {
52	<	try {
53	<	Thread.sleep(SHORT_DELAY_MS);
54	<	LockSupport.park();
55	<	} catch(Exception e){
56	<	threadUnexpectedException();
57	<	}
58	<	}
59	<	});
60	<	try {
61	<	t.start();
62	<	LockSupport.unpark(t);
63	<	t.join();
64	<	}
65	<	catch(Exception e) {
66	<	unexpectedException();
67	<	}
68	<	}
69	<
70	<	/**
71	<	* park is released by interrupt
72	<	*/
73	<	public void testPark3() {
74	<	Thread t = new Thread(new Runnable() {
75	<	public void run() {
76	<	try {
77	<	LockSupport.park();
78	<	threadAssertTrue(Thread.interrupted());
79	<	} catch(Exception e){
80	<	threadUnexpectedException();
81	<	}
82	<	}
83	<	});
84	<	try {
85	<	t.start();
86	<	Thread.sleep(SHORT_DELAY_MS);
87	<	t.interrupt();
88	<	t.join();
89	<	}
90	<	catch(Exception e) {
91	<	unexpectedException();
92	<	}
25	>	public void testPark() throws InterruptedException {
26	>	Thread t = new Thread(new CheckedRunnable() {
27	>	public void realRun() {
28	>	LockSupport.park();
29	>	}});
30	>
31	>	t.start();
32	>	Thread.sleep(SHORT_DELAY_MS);
33	>	LockSupport.unpark(t);
34	>	t.join();
35	>	}
36	>
37	>	/**
38	>	* park is released by unpark occurring before park
39	>	*/
40	>	public void testPark2() throws InterruptedException {
41	>	Thread t = new Thread(new CheckedRunnable() {
42	>	public void realRun() throws InterruptedException {
43	>	Thread.sleep(SHORT_DELAY_MS);
44	>	LockSupport.park();
45	>	}});
46	>
47	>	t.start();
48	>	LockSupport.unpark(t);
49	>	t.join();
50	>	}
51	>
52	>	/**
53	>	* park is released by interrupt
54	>	*/
55	>	public void testPark3() throws InterruptedException {
56	>	Thread t = new Thread(new CheckedRunnable() {
57	>	public void realRun() {
58	>	LockSupport.park();
59	>	}});
60	>
61	>	t.start();
62	>	Thread.sleep(SHORT_DELAY_MS);
63	>	t.interrupt();
64	>	t.join();
65		}
66
67		/**
68		* park returns if interrupted before park
69		*/
70	<	public void testPark4() {
70	>	public void testPark4() throws InterruptedException {
71		final ReentrantLock lock = new ReentrantLock();
72		lock.lock();
73	<	Thread t = new Thread(new Runnable() {
74	<	public void run() {
75	<	try {
76	<	lock.lock();
77	<	LockSupport.park();
78	<	} catch(Exception e){
79	<	threadUnexpectedException();
80	<	}
81	<	}
82	<	});
83	<	try {
112	<	t.start();
113	<	t.interrupt();
114	<	lock.unlock();
115	<	t.join();
116	<	}
117	<	catch(Exception e) {
118	<	unexpectedException();
119	<	}
73	>	Thread t = new Thread(new CheckedRunnable() {
74	>	public void realRun() {
75	>	lock.lock();
76	>	LockSupport.park();
77	>	}});
78	>
79	>	t.start();
80	>	Thread.sleep(SHORT_DELAY_MS);
81	>	t.interrupt();
82	>	lock.unlock();
83	>	t.join();
84		}
85
86		/**
87		* parkNanos times out if not unparked
88		*/
89	<	public void testParkNanos() {
90	<	Thread t = new Thread(new Runnable() {
91	<	public void run() {
92	<	try {
93	<	LockSupport.parkNanos(1000);
94	<	} catch(Exception e){
95	<	threadUnexpectedException();
96	<	}
133	<	}
134	<	});
135	<	try {
136	<	t.start();
137	<	t.join();
138	<	}
139	<	catch(Exception e) {
140	<	unexpectedException();
141	<	}
89	>	public void testParkNanos() throws InterruptedException {
90	>	Thread t = new Thread(new CheckedRunnable() {
91	>	public void realRun() {
92	>	LockSupport.parkNanos(1000);
93	>	}});
94	>
95	>	t.start();
96	>	t.join();
97		}
98
99
100		/**
101		* parkUntil times out if not unparked
102		*/
103	<	public void testParkUntil() {
104	<	Thread t = new Thread(new Runnable() {
105	<	public void run() {
106	<	try {
107	<	long d = new Date().getTime() + 100;
108	<	LockSupport.parkUntil(d);
109	<	} catch(Exception e){
110	<	threadUnexpectedException();
111	<	}
157	<	}
158	<	});
159	<	try {
160	<	t.start();
161	<	t.join();
162	<	}
163	<	catch(Exception e) {
164	<	unexpectedException();
165	<	}
103	>	public void testParkUntil() throws InterruptedException {
104	>	Thread t = new Thread(new CheckedRunnable() {
105	>	public void realRun() {
106	>	long d = new Date().getTime() + 100;
107	>	LockSupport.parkUntil(d);
108	>	}});
109	>
110	>	t.start();
111	>	t.join();
112		}
113		}

Diff Legend

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