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.98 by jsr166, Sun Feb 3 06:20:32 2013 UTC vs.
Revision 1.104 by dl, Thu Mar 21 00:26:43 2013 UTC

# Line 286 | Line 286 | public class JSR166TestCase extends Test
286          // Java8+ test classes
287          if (atLeastJava8()) {
288              String[] java8TestClassNames = {
289 +                "CompletableFutureTest",
290 +                "CountedCompleterTest",
291 +                "DoubleAccumulatorTest",
292 +                "DoubleAdderTest",
293 +                "ForkJoinPool8Test",
294 +                "LongAccumulatorTest",
295 +                "LongAdderTest",
296                  "StampedLockTest",
297              };
298              addNamedTestClasses(suite, java8TestClassNames);
# Line 383 | Line 390 | public class JSR166TestCase extends Test
390  
391          if (Thread.interrupted())
392              throw new AssertionFailedError("interrupt status set in main thread");
393 +
394 +        checkForkJoinPoolThreadLeaks();
395 +    }
396 +
397 +    /**
398 +     * Find missing try { ... } finally { joinPool(e); }
399 +     */
400 +    void checkForkJoinPoolThreadLeaks() throws InterruptedException {
401 +        Thread[] survivors = new Thread[5];
402 +        int count = Thread.enumerate(survivors);
403 +        for (int i = 0; i < count; i++) {
404 +            Thread thread = survivors[i];
405 +            String name = thread.getName();
406 +            if (name.startsWith("ForkJoinPool-")) {
407 +                // give thread some time to terminate
408 +                thread.join(LONG_DELAY_MS);
409 +                if (!thread.isAlive()) continue;
410 +                thread.stop();
411 +                throw new AssertionFailedError
412 +                    (String.format("Found leaked ForkJoinPool thread test=%s thread=%s%n",
413 +                                   toString(), name));
414 +            }
415 +        }
416      }
417  
418      /**

Diff Legend

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