ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/JSR166TestCase.java
(Generate patch)

Comparing jsr166/src/test/tck/JSR166TestCase.java (file contents):
Revision 1.4 by dl, Thu Sep 25 11:02:41 2003 UTC vs.
Revision 1.23 by dl, Tue Dec 28 16:15:59 2004 UTC

# Line 1 | Line 1
1   /*
2 < * Written by members of JCP JSR-166 Expert Group and released to the
3 < * public domain. Use, modify, and redistribute this code in any way
4 < * without acknowledgement. Other contributors include Andrew Wright,
5 < * Jeffrey Hayes, Pat Fischer, Mike Judd.
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.
7   */
8  
9   import junit.framework.*;
10   import java.util.*;
11   import java.util.concurrent.*;
12   import java.io.*;
13 <
13 > import java.security.*;
14  
15   /**
16 < * Base class for JSR166 Junit TCK tests.  Defines some constants and
17 < * utility methods, as well as a simple framework for helping to make
18 < * sure that assertions failing in generated threads cause the
19 < * associated test that generated them to itself fail (which JUnit doe
20 < * not otherwise arrange).  The rules for creating such tests are:
16 > * Base class for JSR166 Junit TCK tests.  Defines some constants,
17 > * utility methods and classes, as well as a simple framework for
18 > * helping to make sure that assertions failing in generated threads
19 > * cause the associated test that generated them to itself fail (which
20 > * JUnit doe not otherwise arrange).  The rules for creating such
21 > * tests are:
22   *
23   * <ol>
24   *
25   * <li> All assertions in code running in generated threads must use
26 < * the forms {@link threadFail} , {@link threadAssertTrue} {@link
27 < * threadAssertEquals}, or {@link threadAssertNull}, (not
26 > * the forms {@link #threadFail} , {@link #threadAssertTrue} {@link
27 > * #threadAssertEquals}, or {@link #threadAssertNull}, (not
28   * <tt>fail</tt>, <tt>assertTrue</tt>, etc.) It is OK (but not
29   * particularly recommended) for other code to use these forms too.
30   * Only the most typically used JUnit assertion methods are defined
31   * this way, but enough to live with.</li>
32   *
33 < * <li> If you override {@link setUp} or {@link tearDown}, make sure
33 > * <li> If you override {@link #setUp} or {@link #tearDown}, make sure
34   * to invoke <tt>super.setUp</tt> and <tt>super.tearDown</tt> within
35   * them. These methods are used to clear and check for thread
36   * assertion failures.</li>
37   *
38 < * <li>All delays and timeouts must use one of the constants {@link
39 < * SHORT_DELAY_MS}, {@link SMALL_DELAY_MS}, {@link MEDIUM_DELAY_MS},
40 < * {@link LONG_DELAY_MS}. The idea here is that a SHORT is always
41 < * discriminatable from zero time, and always allows enough time for
42 < * the small amounts of computation (creating a thread, calling a few
38 > * <li>All delays and timeouts must use one of the constants <tt>
39 > * SHORT_DELAY_MS</tt>, <tt> SMALL_DELAY_MS</tt>, <tt> MEDIUM_DELAY_MS</tt>,
40 > * <tt> LONG_DELAY_MS</tt>. The idea here is that a SHORT is always
41 > * discriminable from zero time, and always allows enough time for the
42 > * small amounts of computation (creating a thread, calling a few
43   * methods, etc) needed to reach a timeout point. Similarly, a SMALL
44   * is always discriminable as larger than SHORT and smaller than
45   * MEDIUM.  And so on. These constants are set to conservative values,
# Line 46 | Line 48 | import java.io.*;
48   *
49   * <li> All threads generated must be joined inside each test case
50   * method (or <tt>fail</tt> to do so) before returning from the
51 < * method. The {@link joinPool} method can be used to do this when
51 > * method. The <tt> joinPool</tt> method can be used to do this when
52   * using Executors.</li>
53   *
54   * </ol>
55 + *
56 + * <p> <b>Other notes</b>
57 + * <ul>
58 + *
59 + * <li> Usually, there is one testcase method per JSR166 method
60 + * covering "normal" operation, and then as many exception-testing
61 + * methods as there are exceptions the method can throw. Sometimes
62 + * there are multiple tests per JSR166 method when the different
63 + * "normal" behaviors differ significantly. And sometimes testcases
64 + * cover multiple methods when they cannot be tested in
65 + * isolation.</li>
66 + *
67 + * <li> The documentation style for testcases is to provide as javadoc
68 + * a simple sentence or two describing the property that the testcase
69 + * method purports to test. The javadocs do not say anything about how
70 + * the property is tested. To find out, read the code.</li>
71 + *
72 + * <li> These tests are "conformance tests", and do not attempt to
73 + * test throughput, latency, scalability or other performance factors
74 + * (see the separate "jtreg" tests for a set intended to check these
75 + * for the most central aspects of functionality.) So, most tests use
76 + * the smallest sensible numbers of threads, collection sizes, etc
77 + * needed to check basic conformance.</li>
78 + *
79 + * <li>The test classes currently do not declare inclusion in
80 + * any particular package to simplify things for people integrating
81 + * them in TCK test suites.</li>
82 + *
83 + * <li> As a convenience, the <tt>main</tt> of this class (JSR166TestCase)
84 + * runs all JSR166 unit tests.</li>
85 + *
86 + * </ul>
87   */
88   public class JSR166TestCase extends TestCase {
89 +    /**
90 +     * Runs all JSR166 unit tests using junit.textui.TestRunner
91 +     */
92 +    public static void main (String[] args) {
93 +        int iters = 1;
94 +        if (args.length > 0)
95 +            iters = Integer.parseInt(args[0]);
96 +        Test s = suite();
97 +        for (int i = 0; i < iters; ++i) {
98 +            junit.textui.TestRunner.run (s);
99 +            System.gc();
100 +            System.runFinalization();
101 +        }
102 +        System.exit(0);
103 +    }
104 +
105 +    /**
106 +     * Collects all JSR166 unit tests as one suite
107 +     */
108 +    public static Test suite ( ) {
109 +        TestSuite suite = new TestSuite("JSR166 Unit Tests");
110 +        
111 +        suite.addTest(new TestSuite(AbstractExecutorServiceTest.class));
112 +        suite.addTest(new TestSuite(AbstractQueueTest.class));
113 +        suite.addTest(new TestSuite(AbstractQueuedSynchronizerTest.class));
114 +        suite.addTest(new TestSuite(ArrayBlockingQueueTest.class));
115 +        suite.addTest(new TestSuite(ArrayDequeTest.class));
116 +        suite.addTest(new TestSuite(AtomicBooleanTest.class));
117 +        suite.addTest(new TestSuite(AtomicIntegerArrayTest.class));
118 +        suite.addTest(new TestSuite(AtomicIntegerFieldUpdaterTest.class));
119 +        suite.addTest(new TestSuite(AtomicIntegerTest.class));
120 +        suite.addTest(new TestSuite(AtomicLongArrayTest.class));
121 +        suite.addTest(new TestSuite(AtomicLongFieldUpdaterTest.class));
122 +        suite.addTest(new TestSuite(AtomicLongTest.class));
123 +        suite.addTest(new TestSuite(AtomicMarkableReferenceTest.class));
124 +        suite.addTest(new TestSuite(AtomicReferenceArrayTest.class));
125 +        suite.addTest(new TestSuite(AtomicReferenceFieldUpdaterTest.class));
126 +        suite.addTest(new TestSuite(AtomicReferenceTest.class));
127 +        suite.addTest(new TestSuite(AtomicStampedReferenceTest.class));
128 +        suite.addTest(new TestSuite(ConcurrentHashMapTest.class));
129 +        suite.addTest(new TestSuite(ConcurrentLinkedQueueTest.class));
130 +        suite.addTest(new TestSuite(ConcurrentSkipListMapTest.class));
131 +        suite.addTest(new TestSuite(ConcurrentSkipListSubMapTest.class));
132 +        suite.addTest(new TestSuite(ConcurrentSkipListSetTest.class));
133 +        suite.addTest(new TestSuite(ConcurrentSkipListSubSetTest.class));
134 +        suite.addTest(new TestSuite(CopyOnWriteArrayListTest.class));
135 +        suite.addTest(new TestSuite(CopyOnWriteArraySetTest.class));
136 +        suite.addTest(new TestSuite(CountDownLatchTest.class));
137 +        suite.addTest(new TestSuite(CyclicBarrierTest.class));
138 +        suite.addTest(new TestSuite(DelayQueueTest.class));
139 +        suite.addTest(new TestSuite(ExchangerTest.class));
140 +        suite.addTest(new TestSuite(ExecutorsTest.class));
141 +        suite.addTest(new TestSuite(ExecutorCompletionServiceTest.class));
142 +        suite.addTest(new TestSuite(FutureTaskTest.class));
143 +        suite.addTest(new TestSuite(LinkedBlockingDequeTest.class));
144 +        suite.addTest(new TestSuite(LinkedBlockingQueueTest.class));
145 +        suite.addTest(new TestSuite(LinkedListTest.class));
146 +        suite.addTest(new TestSuite(LockSupportTest.class));
147 +        suite.addTest(new TestSuite(PriorityBlockingQueueTest.class));
148 +        suite.addTest(new TestSuite(PriorityQueueTest.class));
149 +        suite.addTest(new TestSuite(ReentrantLockTest.class));
150 +        suite.addTest(new TestSuite(ReentrantReadWriteLockTest.class));
151 +        suite.addTest(new TestSuite(ScheduledExecutorTest.class));
152 +        suite.addTest(new TestSuite(SemaphoreTest.class));
153 +        suite.addTest(new TestSuite(SynchronousQueueTest.class));
154 +        suite.addTest(new TestSuite(SystemTest.class));
155 +        suite.addTest(new TestSuite(ThreadLocalTest.class));
156 +        suite.addTest(new TestSuite(ThreadPoolExecutorTest.class));
157 +        suite.addTest(new TestSuite(ThreadTest.class));
158 +        suite.addTest(new TestSuite(TreeMapTest.class));
159 +        suite.addTest(new TestSuite(TreeSetTest.class));
160 +                
161 +        return suite;
162 +    }
163 +
164  
165      public static long SHORT_DELAY_MS;
166      public static long SMALL_DELAY_MS;
# Line 61 | Line 170 | public class JSR166TestCase extends Test
170  
171      /**
172       * Return the shortest timed delay. This could
173 <     * be reimplmented to use for example a Property.
173 >     * be reimplemented to use for example a Property.
174       */
175      protected long getShortDelay() {
176 <        return 100;
176 >        return 50;
177      }
178  
179  
180      /**
181 <     * Set delays as multiples fo SHORT_DELAY.
181 >     * Set delays as multiples of SHORT_DELAY.
182       */
183      protected  void setDelays() {
184          SHORT_DELAY_MS = getShortDelay();
# Line 81 | Line 190 | public class JSR166TestCase extends Test
190      /**
191       * Flag set true if any threadAssert methods fail
192       */
193 <    protected volatile boolean threadFailed;
193 >    volatile boolean threadFailed;
194  
195      /**
196       * Initialize test to indicate that no thread assertions have failed
# Line 98 | Line 207 | public class JSR166TestCase extends Test
207          assertFalse(threadFailed);  
208      }
209  
210 +    /**
211 +     * Fail, also setting status to indicate current testcase should fail
212 +     */
213      public void threadFail(String reason) {
214          threadFailed = true;
215          fail(reason);
216      }
217  
218 +    /**
219 +     * If expression not true, set status to indicate current testcase
220 +     * should fail
221 +     */
222      public void threadAssertTrue(boolean b) {
223          if (!b) {
224              threadFailed = true;
225              assertTrue(b);
226          }
227      }
228 +
229 +    /**
230 +     * If expression not false, set status to indicate current testcase
231 +     * should fail
232 +     */
233      public void threadAssertFalse(boolean b) {
234          if (b) {
235              threadFailed = true;
236              assertFalse(b);
237          }
238      }
239 +
240 +    /**
241 +     * If argument not null, set status to indicate current testcase
242 +     * should fail
243 +     */
244      public void threadAssertNull(Object x) {
245          if (x != null) {
246              threadFailed = true;
247              assertNull(x);
248          }
249      }
250 +
251 +    /**
252 +     * If arguments not equal, set status to indicate current testcase
253 +     * should fail
254 +     */
255      public void threadAssertEquals(long x, long y) {
256          if (x != y) {
257              threadFailed = true;
258              assertEquals(x, y);
259          }
260      }
261 +
262 +    /**
263 +     * If arguments not equal, set status to indicate current testcase
264 +     * should fail
265 +     */
266      public void threadAssertEquals(Object x, Object y) {
267          if (x != y && (x == null || !x.equals(y))) {
268              threadFailed = true;
# Line 134 | Line 270 | public class JSR166TestCase extends Test
270          }
271      }
272  
273 +    /**
274 +     * threadFail with message "should throw exception"
275 +     */
276      public void threadShouldThrow() {
277          threadFailed = true;
278          fail("should throw exception");
279      }
280  
281 +    /**
282 +     * threadFail with message "Unexpected exception"
283 +     */
284      public void threadUnexpectedException() {
285          threadFailed = true;
286          fail("Unexpected exception");
# Line 152 | Line 294 | public class JSR166TestCase extends Test
294          try {
295              exec.shutdown();
296              assertTrue(exec.awaitTermination(LONG_DELAY_MS, TimeUnit.MILLISECONDS));
297 +        } catch(SecurityException ok) {
298 +            // Allowed in case test doesn't have privs
299          } catch(InterruptedException ie) {
300              fail("Unexpected exception");
301          }
302      }
303  
304 <    
304 >
305 >    /**
306 >     * fail with message "should throw exception"
307 >     */
308      public void shouldThrow() {
309          fail("Should throw exception");
310      }
311  
312 +    /**
313 +     * fail with message "Unexpected exception"
314 +     */
315      public void unexpectedException() {
316          fail("Unexpected exception");
317      }
# Line 170 | Line 320 | public class JSR166TestCase extends Test
320      /**
321       * The number of elements to place in collections, arrays, etc.
322       */
323 <    public static final int SIZE = 20;
323 >    static final int SIZE = 20;
324  
325      // Some convenient Integer constants
326  
327 <    public static final Integer zero = new Integer(0);
328 <    public static final Integer one = new Integer(1);
329 <    public static final Integer two = new Integer(2);
330 <    public static final Integer three  = new Integer(3);
331 <    public static final Integer four  = new Integer(4);
332 <    public static final Integer five  = new Integer(5);
333 <    public static final Integer six = new Integer(6);
334 <    public static final Integer seven = new Integer(7);
335 <    public static final Integer eight = new Integer(8);
336 <    public static final Integer nine = new Integer(9);
337 <    public static final Integer m1  = new Integer(-1);
338 <    public static final Integer m2  = new Integer(-2);
339 <    public static final Integer m3  = new Integer(-3);
340 <    public static final Integer m4 = new Integer(-4);
341 <    public static final Integer m5 = new Integer(-5);
342 <    public static final Integer m10 = new Integer(-10);
327 >    static final Integer zero = new Integer(0);
328 >    static final Integer one = new Integer(1);
329 >    static final Integer two = new Integer(2);
330 >    static final Integer three  = new Integer(3);
331 >    static final Integer four  = new Integer(4);
332 >    static final Integer five  = new Integer(5);
333 >    static final Integer six = new Integer(6);
334 >    static final Integer seven = new Integer(7);
335 >    static final Integer eight = new Integer(8);
336 >    static final Integer nine = new Integer(9);
337 >    static final Integer m1  = new Integer(-1);
338 >    static final Integer m2  = new Integer(-2);
339 >    static final Integer m3  = new Integer(-3);
340 >    static final Integer m4 = new Integer(-4);
341 >    static final Integer m5 = new Integer(-5);
342 >    static final Integer m10 = new Integer(-10);
343 >
344 >
345 >    /**
346 >     * A security policy where new permissions can be dynamically added
347 >     * or all cleared.
348 >     */
349 >    static class AdjustablePolicy extends java.security.Policy {
350 >        Permissions perms = new Permissions();
351 >        AdjustablePolicy() { }
352 >        void addPermission(Permission perm) { perms.add(perm); }
353 >        void clearPermissions() { perms = new Permissions(); }
354 >        public PermissionCollection getPermissions(CodeSource cs) {
355 >            return perms;
356 >        }
357 >        public PermissionCollection getPermissions(ProtectionDomain pd) {
358 >            return perms;
359 >        }
360 >        public boolean implies(ProtectionDomain pd, Permission p) {
361 >            return perms.implies(p);
362 >        }
363 >        public void refresh() {}
364 >    }
365  
366  
367      // Some convenient Runnable classes
368  
369 <    public static class NoOpRunnable implements Runnable {
369 >    static class NoOpRunnable implements Runnable {
370          public void run() {}
371      }
372  
373 <    public static class NoOpCallable implements Callable {
373 >    static class NoOpCallable implements Callable {
374          public Object call() { return Boolean.TRUE; }
375      }
376  
377 <    public class ShortRunnable implements Runnable {
377 >    static final String TEST_STRING = "a test string";
378 >
379 >    static class StringTask implements Callable<String> {
380 >        public String call() { return TEST_STRING; }
381 >    }
382 >
383 >    static class NPETask implements Callable<String> {
384 >        public String call() { throw new NullPointerException(); }
385 >    }
386 >
387 >    static class CallableOne implements Callable<Integer> {
388 >        public Integer call() { return one; }
389 >    }
390 >
391 >    class ShortRunnable implements Runnable {
392          public void run() {
393              try {
394                  Thread.sleep(SHORT_DELAY_MS);
# Line 213 | Line 399 | public class JSR166TestCase extends Test
399          }
400      }
401  
402 <    public class ShortInterruptedRunnable implements Runnable {
402 >    class ShortInterruptedRunnable implements Runnable {
403          public void run() {
404              try {
405                  Thread.sleep(SHORT_DELAY_MS);
# Line 224 | Line 410 | public class JSR166TestCase extends Test
410          }
411      }
412  
413 <    public class SmallRunnable implements Runnable {
413 >    class SmallRunnable implements Runnable {
414          public void run() {
415              try {
416                  Thread.sleep(SMALL_DELAY_MS);
# Line 235 | Line 421 | public class JSR166TestCase extends Test
421          }
422      }
423  
424 <    public class SmallCallable implements Callable {
424 >    class SmallPossiblyInterruptedRunnable implements Runnable {
425 >        public void run() {
426 >            try {
427 >                Thread.sleep(SMALL_DELAY_MS);
428 >            }
429 >            catch(Exception e) {
430 >            }
431 >        }
432 >    }
433 >
434 >    class SmallCallable implements Callable {
435          public Object call() {
436              try {
437                  Thread.sleep(SMALL_DELAY_MS);
# Line 247 | Line 443 | public class JSR166TestCase extends Test
443          }
444      }
445  
446 <    public class SmallInterruptedRunnable implements Runnable {
446 >    class SmallInterruptedRunnable implements Runnable {
447          public void run() {
448              try {
449                  Thread.sleep(SMALL_DELAY_MS);
# Line 259 | Line 455 | public class JSR166TestCase extends Test
455      }
456  
457  
458 <    public class MediumRunnable implements Runnable {
458 >    class MediumRunnable implements Runnable {
459          public void run() {
460              try {
461                  Thread.sleep(MEDIUM_DELAY_MS);
# Line 270 | Line 466 | public class JSR166TestCase extends Test
466          }
467      }
468  
469 <    public class MediumInterruptedRunnable implements Runnable {
469 >    class MediumInterruptedRunnable implements Runnable {
470          public void run() {
471              try {
472                  Thread.sleep(MEDIUM_DELAY_MS);
# Line 281 | Line 477 | public class JSR166TestCase extends Test
477          }
478      }
479  
480 <    public class MediumPossiblyInterruptedRunnable implements Runnable {
480 >    class MediumPossiblyInterruptedRunnable implements Runnable {
481          public void run() {
482              try {
483                  Thread.sleep(MEDIUM_DELAY_MS);
# Line 290 | Line 486 | public class JSR166TestCase extends Test
486              }
487          }
488      }
489 +
490 +    class LongPossiblyInterruptedRunnable implements Runnable {
491 +        public void run() {
492 +            try {
493 +                Thread.sleep(LONG_DELAY_MS);
494 +            }
495 +            catch(InterruptedException success) {
496 +            }
497 +        }
498 +    }
499 +
500 +    /**
501 +     * For use as ThreadFactory in constructors
502 +     */
503 +    static class SimpleThreadFactory implements ThreadFactory{
504 +        public Thread newThread(Runnable r){
505 +            return new Thread(r);
506 +        }  
507 +    }
508 +
509 +    static class TrackedShortRunnable implements Runnable {
510 +        volatile boolean done = false;
511 +        public void run() {
512 +            try {
513 +                Thread.sleep(SMALL_DELAY_MS);
514 +                done = true;
515 +            } catch(Exception e){
516 +            }
517 +        }
518 +    }
519 +
520 +    static class TrackedMediumRunnable implements Runnable {
521 +        volatile boolean done = false;
522 +        public void run() {
523 +            try {
524 +                Thread.sleep(MEDIUM_DELAY_MS);
525 +                done = true;
526 +            } catch(Exception e){
527 +            }
528 +        }
529 +    }
530 +
531 +    static class TrackedLongRunnable implements Runnable {
532 +        volatile boolean done = false;
533 +        public void run() {
534 +            try {
535 +                Thread.sleep(LONG_DELAY_MS);
536 +                done = true;
537 +            } catch(Exception e){
538 +            }
539 +        }
540 +    }
541 +
542 +    static class TrackedNoOpRunnable implements Runnable {
543 +        volatile boolean done = false;
544 +        public void run() {
545 +            done = true;
546 +        }
547 +    }
548 +
549 +    static class TrackedCallable implements Callable {
550 +        volatile boolean done = false;
551 +        public Object call() {
552 +            try {
553 +                Thread.sleep(SMALL_DELAY_MS);
554 +                done = true;
555 +            } catch(Exception e){
556 +            }
557 +            return Boolean.TRUE;
558 +        }
559 +    }
560 +
561 +
562 +    /**
563 +     * For use as RejectedExecutionHandler in constructors
564 +     */
565 +    static class NoOpREHandler implements RejectedExecutionHandler{
566 +        public void rejectedExecution(Runnable r, ThreadPoolExecutor executor){}
567 +    }
568 +
569      
570   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines