test/tck/LockSupportTest.java

/*
 * Written by Doug Lea and Martin Buchholz with assistance from
 * members of JCP JSR-166 Expert Group and released to the public
 * domain, as explained at
 * http://creativecommons.org/publicdomain/zero/1.0/
 * Other contributors include Andrew Wright, Jeffrey Hayes,
 * Pat Fisher, Mike Judd.
 */

import static java.util.concurrent.TimeUnit.MILLISECONDS;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.LockSupport;

import junit.framework.Test;
import junit.framework.TestSuite;

public class LockSupportTest extends JSR166TestCase {
    public static void main(String[] args) {
        main(suite(), args);
    }

    public static Test suite() {
        return new TestSuite(LockSupportTest.class);
    }

    /**
     * Returns the blocker object used by tests in this file.
     * Any old object will do; we'll return a convenient one.
     */
    static Object theBlocker() {
        return LockSupportTest.class;
    }

    enum ParkMethod {
        park() {
            void park() {
                LockSupport.park();
            }
            void park(long millis) {
                throw new UnsupportedOperationException();
            }
        },
        parkUntil() {
            void park(long millis) {
                LockSupport.parkUntil(deadline(millis));
            }
        },
        parkNanos() {
            void park(long millis) {
                LockSupport.parkNanos(MILLISECONDS.toNanos(millis));
            }
        },
        parkBlocker() {
            void park() {
                LockSupport.park(theBlocker());
            }
            void park(long millis) {
                throw new UnsupportedOperationException();
            }
        },
        parkUntilBlocker() {
            void park(long millis) {
                LockSupport.parkUntil(theBlocker(), deadline(millis));
            }
        },
        parkNanosBlocker() {
            void park(long millis) {
                LockSupport.parkNanos(theBlocker(),
                                      MILLISECONDS.toNanos(millis));
            }
        };

        void park() { park(2 * LONG_DELAY_MS); }
        abstract void park(long millis);

        /** Returns a deadline to use with parkUntil. */
        long deadline(long millis) {
            // beware of rounding
            return System.currentTimeMillis() + millis + 1;
        }
    }

    /**
     * park is released by subsequent unpark
     */
    public void testParkBeforeUnpark_park() {
        testParkBeforeUnpark(ParkMethod.park);
    }
    public void testParkBeforeUnpark_parkNanos() {
        testParkBeforeUnpark(ParkMethod.parkNanos);
    }
    public void testParkBeforeUnpark_parkUntil() {
        testParkBeforeUnpark(ParkMethod.parkUntil);
    }
    public void testParkBeforeUnpark_parkBlocker() {
        testParkBeforeUnpark(ParkMethod.parkBlocker);
    }
    public void testParkBeforeUnpark_parkNanosBlocker() {
        testParkBeforeUnpark(ParkMethod.parkNanosBlocker);
    }
    public void testParkBeforeUnpark_parkUntilBlocker() {
        testParkBeforeUnpark(ParkMethod.parkUntilBlocker);
    }
    public void testParkBeforeUnpark(final ParkMethod parkMethod) {
        final CountDownLatch pleaseUnpark = new CountDownLatch(1);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                pleaseUnpark.countDown();
                parkMethod.park();
            }});

        await(pleaseUnpark);
        LockSupport.unpark(t);
        awaitTermination(t);
    }

    /**
     * park is released by preceding unpark
     */
    public void testParkAfterUnpark_park() {
        testParkAfterUnpark(ParkMethod.park);
    }
    public void testParkAfterUnpark_parkNanos() {
        testParkAfterUnpark(ParkMethod.parkNanos);
    }
    public void testParkAfterUnpark_parkUntil() {
        testParkAfterUnpark(ParkMethod.parkUntil);
    }
    public void testParkAfterUnpark_parkBlocker() {
        testParkAfterUnpark(ParkMethod.parkBlocker);
    }
    public void testParkAfterUnpark_parkNanosBlocker() {
        testParkAfterUnpark(ParkMethod.parkNanosBlocker);
    }
    public void testParkAfterUnpark_parkUntilBlocker() {
        testParkAfterUnpark(ParkMethod.parkUntilBlocker);
    }
    public void testParkAfterUnpark(final ParkMethod parkMethod) {
        final CountDownLatch pleaseUnpark = new CountDownLatch(1);
        final AtomicBoolean pleasePark = new AtomicBoolean(false);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                pleaseUnpark.countDown();
                while (!pleasePark.get())
                    Thread.yield();
                parkMethod.park();
            }});

        await(pleaseUnpark);
        LockSupport.unpark(t);
        pleasePark.set(true);
        awaitTermination(t);
    }

    /**
     * park is released by subsequent interrupt
     */
    public void testParkBeforeInterrupt_park() {
        testParkBeforeInterrupt(ParkMethod.park);
    }
    public void testParkBeforeInterrupt_parkNanos() {
        testParkBeforeInterrupt(ParkMethod.parkNanos);
    }
    public void testParkBeforeInterrupt_parkUntil() {
        testParkBeforeInterrupt(ParkMethod.parkUntil);
    }
    public void testParkBeforeInterrupt_parkBlocker() {
        testParkBeforeInterrupt(ParkMethod.parkBlocker);
    }
    public void testParkBeforeInterrupt_parkNanosBlocker() {
        testParkBeforeInterrupt(ParkMethod.parkNanosBlocker);
    }
    public void testParkBeforeInterrupt_parkUntilBlocker() {
        testParkBeforeInterrupt(ParkMethod.parkUntilBlocker);
    }
    public void testParkBeforeInterrupt(final ParkMethod parkMethod) {
        final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                pleaseInterrupt.countDown();
                do {
                    parkMethod.park();
                    // park may return spuriously
                } while (! Thread.currentThread().isInterrupted());
            }});

        await(pleaseInterrupt);
        assertThreadStaysAlive(t);
        t.interrupt();
        awaitTermination(t);
    }

    /**
     * park is released by preceding interrupt
     */
    public void testParkAfterInterrupt_park() {
        testParkAfterInterrupt(ParkMethod.park);
    }
    public void testParkAfterInterrupt_parkNanos() {
        testParkAfterInterrupt(ParkMethod.parkNanos);
    }
    public void testParkAfterInterrupt_parkUntil() {
        testParkAfterInterrupt(ParkMethod.parkUntil);
    }
    public void testParkAfterInterrupt_parkBlocker() {
        testParkAfterInterrupt(ParkMethod.parkBlocker);
    }
    public void testParkAfterInterrupt_parkNanosBlocker() {
        testParkAfterInterrupt(ParkMethod.parkNanosBlocker);
    }
    public void testParkAfterInterrupt_parkUntilBlocker() {
        testParkAfterInterrupt(ParkMethod.parkUntilBlocker);
    }
    public void testParkAfterInterrupt(final ParkMethod parkMethod) {
        final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
        final AtomicBoolean pleasePark = new AtomicBoolean(false);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() throws Exception {
                pleaseInterrupt.countDown();
                while (!pleasePark.get())
                    Thread.yield();
                assertTrue(Thread.currentThread().isInterrupted());
                parkMethod.park();
                assertTrue(Thread.currentThread().isInterrupted());
            }});

        await(pleaseInterrupt);
        t.interrupt();
        pleasePark.set(true);
        awaitTermination(t);
    }

    /**
     * timed park times out if not unparked
     */
    public void testParkTimesOut_parkNanos() {
        testParkTimesOut(ParkMethod.parkNanos);
    }
    public void testParkTimesOut_parkUntil() {
        testParkTimesOut(ParkMethod.parkUntil);
    }
    public void testParkTimesOut_parkNanosBlocker() {
        testParkTimesOut(ParkMethod.parkNanosBlocker);
    }
    public void testParkTimesOut_parkUntilBlocker() {
        testParkTimesOut(ParkMethod.parkUntilBlocker);
    }
    public void testParkTimesOut(final ParkMethod parkMethod) {
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                for (;;) {
                    long startTime = System.nanoTime();
                    parkMethod.park(timeoutMillis());
                    // park may return spuriously
                    if (millisElapsedSince(startTime) >= timeoutMillis())
                        return;
                }
            }});

        awaitTermination(t);
    }

    /**
     * getBlocker(null) throws NullPointerException
     */
    public void testGetBlockerNull() {
        try {
            LockSupport.getBlocker(null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * getBlocker returns the blocker object passed to park
     */
    public void testGetBlocker_parkBlocker() {
        testGetBlocker(ParkMethod.parkBlocker);
    }
    public void testGetBlocker_parkNanosBlocker() {
        testGetBlocker(ParkMethod.parkNanosBlocker);
    }
    public void testGetBlocker_parkUntilBlocker() {
        testGetBlocker(ParkMethod.parkUntilBlocker);
    }
    public void testGetBlocker(final ParkMethod parkMethod) {
        final CountDownLatch started = new CountDownLatch(1);
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                Thread t = Thread.currentThread();
                started.countDown();
                do {
                    assertNull(LockSupport.getBlocker(t));
                    parkMethod.park();
                    assertNull(LockSupport.getBlocker(t));
                    // park may return spuriously
                } while (! Thread.currentThread().isInterrupted());
            }});

        long startTime = System.nanoTime();
        await(started);
        for (;;) {
            Object x = LockSupport.getBlocker(t);
            if (x == theBlocker()) { // success
                t.interrupt();
                awaitTermination(t);
                assertNull(LockSupport.getBlocker(t));
                return;
            } else {
                assertNull(x);  // ok
                if (millisElapsedSince(startTime) > LONG_DELAY_MS)
                    fail("timed out");
                Thread.yield();
            }
        }
    }

    /**
     * timed park(0) returns immediately.
     *
     * Requires hotspot fix for:
     * 6763959 java.util.concurrent.locks.LockSupport.parkUntil(0) blocks forever
     * which is in jdk7-b118 and 6u25.
     */
    public void testPark0_parkNanos() {
        testPark0(ParkMethod.parkNanos);
    }
    public void testPark0_parkUntil() {
        testPark0(ParkMethod.parkUntil);
    }
    public void testPark0_parkNanosBlocker() {
        testPark0(ParkMethod.parkNanosBlocker);
    }
    public void testPark0_parkUntilBlocker() {
        testPark0(ParkMethod.parkUntilBlocker);
    }
    public void testPark0(final ParkMethod parkMethod) {
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                parkMethod.park(0L);
            }});

        awaitTermination(t);
    }

    /**
     * timed park(Long.MIN_VALUE) returns immediately.
     */
    public void testParkNeg_parkNanos() {
        testParkNeg(ParkMethod.parkNanos);
    }
    public void testParkNeg_parkUntil() {
        testParkNeg(ParkMethod.parkUntil);
    }
    public void testParkNeg_parkNanosBlocker() {
        testParkNeg(ParkMethod.parkNanosBlocker);
    }
    public void testParkNeg_parkUntilBlocker() {
        testParkNeg(ParkMethod.parkUntilBlocker);
    }
    public void testParkNeg(final ParkMethod parkMethod) {
        Thread t = newStartedThread(new CheckedRunnable() {
            public void realRun() {
                parkMethod.park(Long.MIN_VALUE);
            }});

        awaitTermination(t);
    }
}
Revision:	1.25
Committed:	Sat Apr 25 04:55:31 2015 UTC (9 years ago) by jsr166
Branch:	MAIN
Changes since 1.24:	+1 -1 lines
Log Message:	improve main methods; respect system properties; actually fail if a test fails
#	Content
1	/*
2	* Written by Doug Lea and Martin Buchholz with assistance from
3	* members of JCP JSR-166 Expert Group and released to the public
4	* domain, as explained at
5	* http://creativecommons.org/publicdomain/zero/1.0/
6	* Other contributors include Andrew Wright, Jeffrey Hayes,
7	* Pat Fisher, Mike Judd.
8	*/
9
10	import static java.util.concurrent.TimeUnit.MILLISECONDS;
11
12	import java.util.concurrent.CountDownLatch;
13	import java.util.concurrent.atomic.AtomicBoolean;
14	import java.util.concurrent.locks.LockSupport;
15
16	import junit.framework.Test;
17	import junit.framework.TestSuite;
18
19	public class LockSupportTest extends JSR166TestCase {
20	public static void main(String[] args) {
21	main(suite(), args);
22	}
23
24	public static Test suite() {
25	return new TestSuite(LockSupportTest.class);
26	}
27
28	/**
29	* Returns the blocker object used by tests in this file.
30	* Any old object will do; we'll return a convenient one.
31	*/
32	static Object theBlocker() {
33	return LockSupportTest.class;
34	}
35
36	enum ParkMethod {
37	park() {
38	void park() {
39	LockSupport.park();
40	}
41	void park(long millis) {
42	throw new UnsupportedOperationException();
43	}
44	},
45	parkUntil() {
46	void park(long millis) {
47	LockSupport.parkUntil(deadline(millis));
48	}
49	},
50	parkNanos() {
51	void park(long millis) {
52	LockSupport.parkNanos(MILLISECONDS.toNanos(millis));
53	}
54	},
55	parkBlocker() {
56	void park() {
57	LockSupport.park(theBlocker());
58	}
59	void park(long millis) {
60	throw new UnsupportedOperationException();
61	}
62	},
63	parkUntilBlocker() {
64	void park(long millis) {
65	LockSupport.parkUntil(theBlocker(), deadline(millis));
66	}
67	},
68	parkNanosBlocker() {
69	void park(long millis) {
70	LockSupport.parkNanos(theBlocker(),
71	MILLISECONDS.toNanos(millis));
72	}
73	};
74
75	void park() { park(2 * LONG_DELAY_MS); }
76	abstract void park(long millis);
77
78	/** Returns a deadline to use with parkUntil. */
79	long deadline(long millis) {
80	// beware of rounding
81	return System.currentTimeMillis() + millis + 1;
82	}
83	}
84
85	/**
86	* park is released by subsequent unpark
87	*/
88	public void testParkBeforeUnpark_park() {
89	testParkBeforeUnpark(ParkMethod.park);
90	}
91	public void testParkBeforeUnpark_parkNanos() {
92	testParkBeforeUnpark(ParkMethod.parkNanos);
93	}
94	public void testParkBeforeUnpark_parkUntil() {
95	testParkBeforeUnpark(ParkMethod.parkUntil);
96	}
97	public void testParkBeforeUnpark_parkBlocker() {
98	testParkBeforeUnpark(ParkMethod.parkBlocker);
99	}
100	public void testParkBeforeUnpark_parkNanosBlocker() {
101	testParkBeforeUnpark(ParkMethod.parkNanosBlocker);
102	}
103	public void testParkBeforeUnpark_parkUntilBlocker() {
104	testParkBeforeUnpark(ParkMethod.parkUntilBlocker);
105	}
106	public void testParkBeforeUnpark(final ParkMethod parkMethod) {
107	final CountDownLatch pleaseUnpark = new CountDownLatch(1);
108	Thread t = newStartedThread(new CheckedRunnable() {
109	public void realRun() {
110	pleaseUnpark.countDown();
111	parkMethod.park();
112	}});
113
114	await(pleaseUnpark);
115	LockSupport.unpark(t);
116	awaitTermination(t);
117	}
118
119	/**
120	* park is released by preceding unpark
121	*/
122	public void testParkAfterUnpark_park() {
123	testParkAfterUnpark(ParkMethod.park);
124	}
125	public void testParkAfterUnpark_parkNanos() {
126	testParkAfterUnpark(ParkMethod.parkNanos);
127	}
128	public void testParkAfterUnpark_parkUntil() {
129	testParkAfterUnpark(ParkMethod.parkUntil);
130	}
131	public void testParkAfterUnpark_parkBlocker() {
132	testParkAfterUnpark(ParkMethod.parkBlocker);
133	}
134	public void testParkAfterUnpark_parkNanosBlocker() {
135	testParkAfterUnpark(ParkMethod.parkNanosBlocker);
136	}
137	public void testParkAfterUnpark_parkUntilBlocker() {
138	testParkAfterUnpark(ParkMethod.parkUntilBlocker);
139	}
140	public void testParkAfterUnpark(final ParkMethod parkMethod) {
141	final CountDownLatch pleaseUnpark = new CountDownLatch(1);
142	final AtomicBoolean pleasePark = new AtomicBoolean(false);
143	Thread t = newStartedThread(new CheckedRunnable() {
144	public void realRun() {
145	pleaseUnpark.countDown();
146	while (!pleasePark.get())
147	Thread.yield();
148	parkMethod.park();
149	}});
150
151	await(pleaseUnpark);
152	LockSupport.unpark(t);
153	pleasePark.set(true);
154	awaitTermination(t);
155	}
156
157	/**
158	* park is released by subsequent interrupt
159	*/
160	public void testParkBeforeInterrupt_park() {
161	testParkBeforeInterrupt(ParkMethod.park);
162	}
163	public void testParkBeforeInterrupt_parkNanos() {
164	testParkBeforeInterrupt(ParkMethod.parkNanos);
165	}
166	public void testParkBeforeInterrupt_parkUntil() {
167	testParkBeforeInterrupt(ParkMethod.parkUntil);
168	}
169	public void testParkBeforeInterrupt_parkBlocker() {
170	testParkBeforeInterrupt(ParkMethod.parkBlocker);
171	}
172	public void testParkBeforeInterrupt_parkNanosBlocker() {
173	testParkBeforeInterrupt(ParkMethod.parkNanosBlocker);
174	}
175	public void testParkBeforeInterrupt_parkUntilBlocker() {
176	testParkBeforeInterrupt(ParkMethod.parkUntilBlocker);
177	}
178	public void testParkBeforeInterrupt(final ParkMethod parkMethod) {
179	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
180	Thread t = newStartedThread(new CheckedRunnable() {
181	public void realRun() {
182	pleaseInterrupt.countDown();
183	do {
184	parkMethod.park();
185	// park may return spuriously
186	} while (! Thread.currentThread().isInterrupted());
187	}});
188
189	await(pleaseInterrupt);
190	assertThreadStaysAlive(t);
191	t.interrupt();
192	awaitTermination(t);
193	}
194
195	/**
196	* park is released by preceding interrupt
197	*/
198	public void testParkAfterInterrupt_park() {
199	testParkAfterInterrupt(ParkMethod.park);
200	}
201	public void testParkAfterInterrupt_parkNanos() {
202	testParkAfterInterrupt(ParkMethod.parkNanos);
203	}
204	public void testParkAfterInterrupt_parkUntil() {
205	testParkAfterInterrupt(ParkMethod.parkUntil);
206	}
207	public void testParkAfterInterrupt_parkBlocker() {
208	testParkAfterInterrupt(ParkMethod.parkBlocker);
209	}
210	public void testParkAfterInterrupt_parkNanosBlocker() {
211	testParkAfterInterrupt(ParkMethod.parkNanosBlocker);
212	}
213	public void testParkAfterInterrupt_parkUntilBlocker() {
214	testParkAfterInterrupt(ParkMethod.parkUntilBlocker);
215	}
216	public void testParkAfterInterrupt(final ParkMethod parkMethod) {
217	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
218	final AtomicBoolean pleasePark = new AtomicBoolean(false);
219	Thread t = newStartedThread(new CheckedRunnable() {
220	public void realRun() throws Exception {
221	pleaseInterrupt.countDown();
222	while (!pleasePark.get())
223	Thread.yield();
224	assertTrue(Thread.currentThread().isInterrupted());
225	parkMethod.park();
226	assertTrue(Thread.currentThread().isInterrupted());
227	}});
228
229	await(pleaseInterrupt);
230	t.interrupt();
231	pleasePark.set(true);
232	awaitTermination(t);
233	}
234
235	/**
236	* timed park times out if not unparked
237	*/
238	public void testParkTimesOut_parkNanos() {
239	testParkTimesOut(ParkMethod.parkNanos);
240	}
241	public void testParkTimesOut_parkUntil() {
242	testParkTimesOut(ParkMethod.parkUntil);
243	}
244	public void testParkTimesOut_parkNanosBlocker() {
245	testParkTimesOut(ParkMethod.parkNanosBlocker);
246	}
247	public void testParkTimesOut_parkUntilBlocker() {
248	testParkTimesOut(ParkMethod.parkUntilBlocker);
249	}
250	public void testParkTimesOut(final ParkMethod parkMethod) {
251	Thread t = newStartedThread(new CheckedRunnable() {
252	public void realRun() {
253	for (;;) {
254	long startTime = System.nanoTime();
255	parkMethod.park(timeoutMillis());
256	// park may return spuriously
257	if (millisElapsedSince(startTime) >= timeoutMillis())
258	return;
259	}
260	}});
261
262	awaitTermination(t);
263	}
264
265	/**
266	* getBlocker(null) throws NullPointerException
267	*/
268	public void testGetBlockerNull() {
269	try {
270	LockSupport.getBlocker(null);
271	shouldThrow();
272	} catch (NullPointerException success) {}
273	}
274
275	/**
276	* getBlocker returns the blocker object passed to park
277	*/
278	public void testGetBlocker_parkBlocker() {
279	testGetBlocker(ParkMethod.parkBlocker);
280	}
281	public void testGetBlocker_parkNanosBlocker() {
282	testGetBlocker(ParkMethod.parkNanosBlocker);
283	}
284	public void testGetBlocker_parkUntilBlocker() {
285	testGetBlocker(ParkMethod.parkUntilBlocker);
286	}
287	public void testGetBlocker(final ParkMethod parkMethod) {
288	final CountDownLatch started = new CountDownLatch(1);
289	Thread t = newStartedThread(new CheckedRunnable() {
290	public void realRun() {
291	Thread t = Thread.currentThread();
292	started.countDown();
293	do {
294	assertNull(LockSupport.getBlocker(t));
295	parkMethod.park();
296	assertNull(LockSupport.getBlocker(t));
297	// park may return spuriously
298	} while (! Thread.currentThread().isInterrupted());
299	}});
300
301	long startTime = System.nanoTime();
302	await(started);
303	for (;;) {
304	Object x = LockSupport.getBlocker(t);
305	if (x == theBlocker()) { // success
306	t.interrupt();
307	awaitTermination(t);
308	assertNull(LockSupport.getBlocker(t));
309	return;
310	} else {
311	assertNull(x); // ok
312	if (millisElapsedSince(startTime) > LONG_DELAY_MS)
313	fail("timed out");
314	Thread.yield();
315	}
316	}
317	}
318
319	/**
320	* timed park(0) returns immediately.
321	*
322	* Requires hotspot fix for:
323	* 6763959 java.util.concurrent.locks.LockSupport.parkUntil(0) blocks forever
324	* which is in jdk7-b118 and 6u25.
325	*/
326	public void testPark0_parkNanos() {
327	testPark0(ParkMethod.parkNanos);
328	}
329	public void testPark0_parkUntil() {
330	testPark0(ParkMethod.parkUntil);
331	}
332	public void testPark0_parkNanosBlocker() {
333	testPark0(ParkMethod.parkNanosBlocker);
334	}
335	public void testPark0_parkUntilBlocker() {
336	testPark0(ParkMethod.parkUntilBlocker);
337	}
338	public void testPark0(final ParkMethod parkMethod) {
339	Thread t = newStartedThread(new CheckedRunnable() {
340	public void realRun() {
341	parkMethod.park(0L);
342	}});
343
344	awaitTermination(t);
345	}
346
347	/**
348	* timed park(Long.MIN_VALUE) returns immediately.
349	*/
350	public void testParkNeg_parkNanos() {
351	testParkNeg(ParkMethod.parkNanos);
352	}
353	public void testParkNeg_parkUntil() {
354	testParkNeg(ParkMethod.parkUntil);
355	}
356	public void testParkNeg_parkNanosBlocker() {
357	testParkNeg(ParkMethod.parkNanosBlocker);
358	}
359	public void testParkNeg_parkUntilBlocker() {
360	testParkNeg(ParkMethod.parkUntilBlocker);
361	}
362	public void testParkNeg(final ParkMethod parkMethod) {
363	Thread t = newStartedThread(new CheckedRunnable() {
364	public void realRun() {
365	parkMethod.park(Long.MIN_VALUE);
366	}});
367
368	awaitTermination(t);
369	}
370	}