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
|