< prev index next >

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

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


 118         assertNull(a.getRawResult());
 119 
 120         {
 121             Thread.currentThread().interrupt();
 122             long startTime = System.nanoTime();
 123             assertNull(a.join());
 124             assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
 125             Thread.interrupted();
 126         }
 127 
 128         {
 129             Thread.currentThread().interrupt();
 130             long startTime = System.nanoTime();
 131             a.quietlyJoin();        // should be no-op
 132             assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
 133             Thread.interrupted();
 134         }
 135 
 136         assertFalse(a.cancel(false));
 137         assertFalse(a.cancel(true));


 138         try {
 139             assertNull(a.get());
 140             assertNull(a.get(randomTimeout(), randomTimeUnit()));
 141         } catch (Throwable fail) { threadUnexpectedException(fail); }


 142     }
 143 
 144     void checkCancelled(CountedCompleter a) {
 145         assertTrue(a.isDone());
 146         assertTrue(a.isCancelled());
 147         assertFalse(a.isCompletedNormally());
 148         assertTrue(a.isCompletedAbnormally());
 149         assertTrue(a.getException() instanceof CancellationException);
 150         assertNull(a.getRawResult());
 151         assertTrue(a.cancel(false));
 152         assertTrue(a.cancel(true));
 153 
 154         try {
 155             Thread.currentThread().interrupt();
 156             a.join();
 157             shouldThrow();
 158         } catch (CancellationException success) {
 159         } catch (Throwable fail) { threadUnexpectedException(fail); }
 160         Thread.interrupted();
 161 




 118         assertNull(a.getRawResult());
 119 
 120         {
 121             Thread.currentThread().interrupt();
 122             long startTime = System.nanoTime();
 123             assertNull(a.join());
 124             assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
 125             Thread.interrupted();
 126         }
 127 
 128         {
 129             Thread.currentThread().interrupt();
 130             long startTime = System.nanoTime();
 131             a.quietlyJoin();        // should be no-op
 132             assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
 133             Thread.interrupted();
 134         }
 135 
 136         assertFalse(a.cancel(false));
 137         assertFalse(a.cancel(true));
 138 
 139         Object v1 = null, v2 = null;
 140         try {
 141             v1 = a.get();
 142             v2 = a.get(randomTimeout(), randomTimeUnit());
 143         } catch (Throwable fail) { threadUnexpectedException(fail); }
 144         assertNull(v1);
 145         assertNull(v2);
 146     }
 147 
 148     void checkCancelled(CountedCompleter a) {
 149         assertTrue(a.isDone());
 150         assertTrue(a.isCancelled());
 151         assertFalse(a.isCompletedNormally());
 152         assertTrue(a.isCompletedAbnormally());
 153         assertTrue(a.getException() instanceof CancellationException);
 154         assertNull(a.getRawResult());
 155         assertTrue(a.cancel(false));
 156         assertTrue(a.cancel(true));
 157 
 158         try {
 159             Thread.currentThread().interrupt();
 160             a.join();
 161             shouldThrow();
 162         } catch (CancellationException success) {
 163         } catch (Throwable fail) { threadUnexpectedException(fail); }
 164         Thread.interrupted();
 165 


< prev index next >