< prev index next >

test/jdk/java/util/concurrent/tck/ForkJoinTaskTest.java

Print this page
8207003: Miscellaneous changes imported from jsr166 CVS 2018-09
Reviewed-by: martin, chegar

*** 112,133 **** <T> void checkCompletedNormally(ForkJoinTask<T> a) { checkCompletedNormally(a, null); } ! <T> void checkCompletedNormally(ForkJoinTask<T> a, T expected) { assertTrue(a.isDone()); assertFalse(a.isCancelled()); assertTrue(a.isCompletedNormally()); assertFalse(a.isCompletedAbnormally()); assertNull(a.getException()); ! assertSame(expected, a.getRawResult()); { Thread.currentThread().interrupt(); long startTime = System.nanoTime(); ! assertSame(expected, a.join()); assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); Thread.interrupted(); } { --- 112,133 ---- <T> void checkCompletedNormally(ForkJoinTask<T> a) { checkCompletedNormally(a, null); } ! <T> void checkCompletedNormally(ForkJoinTask<T> a, T expectedValue) { assertTrue(a.isDone()); assertFalse(a.isCancelled()); assertTrue(a.isCompletedNormally()); assertFalse(a.isCompletedAbnormally()); assertNull(a.getException()); ! assertSame(expectedValue, a.getRawResult()); { Thread.currentThread().interrupt(); long startTime = System.nanoTime(); ! assertSame(expectedValue, a.join()); assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); Thread.interrupted(); } {
*** 138,151 **** Thread.interrupted(); } assertFalse(a.cancel(false)); assertFalse(a.cancel(true)); try { ! assertSame(expected, a.get()); ! assertSame(expected, a.get(randomTimeout(), randomTimeUnit())); } catch (Throwable fail) { threadUnexpectedException(fail); } } void checkCancelled(ForkJoinTask a) { assertTrue(a.isDone()); assertTrue(a.isCancelled()); --- 138,155 ---- Thread.interrupted(); } assertFalse(a.cancel(false)); assertFalse(a.cancel(true)); + + T v1 = null, v2 = null; try { ! v1 = a.get(); ! v2 = a.get(randomTimeout(), randomTimeUnit()); } catch (Throwable fail) { threadUnexpectedException(fail); } + assertSame(expectedValue, v1); + assertSame(expectedValue, v2); } void checkCancelled(ForkJoinTask a) { assertTrue(a.isDone()); assertTrue(a.isCancelled());
< prev index next >