116 } catch (Throwable fail) { threadUnexpectedException(fail); }
117 }
118
119 try {
120 a.get(randomExpiredTimeout(), randomTimeUnit());
121 shouldThrow();
122 } catch (TimeoutException success) {
123 } catch (Throwable fail) { threadUnexpectedException(fail); }
124 }
125
126 void checkCompletedNormally(ForkJoinTask a) {
127 assertTrue(a.isDone());
128 assertFalse(a.isCancelled());
129 assertTrue(a.isCompletedNormally());
130 assertFalse(a.isCompletedAbnormally());
131 assertNull(a.getException());
132 assertNull(a.getRawResult());
133 assertNull(a.join());
134 assertFalse(a.cancel(false));
135 assertFalse(a.cancel(true));
136 try {
137 assertNull(a.get());
138 assertNull(a.get(randomTimeout(), randomTimeUnit()));
139 } catch (Throwable fail) { threadUnexpectedException(fail); }
140 }
141
142 void checkCancelled(ForkJoinTask a) {
143 assertTrue(a.isDone());
144 assertTrue(a.isCancelled());
145 assertFalse(a.isCompletedNormally());
146 assertTrue(a.isCompletedAbnormally());
147 assertTrue(a.getException() instanceof CancellationException);
148 assertNull(a.getRawResult());
149
150 try {
151 a.join();
152 shouldThrow();
153 } catch (CancellationException success) {
154 } catch (Throwable fail) { threadUnexpectedException(fail); }
155
156 try {
157 a.get();
158 shouldThrow();
159 } catch (CancellationException success) {
|
116 } catch (Throwable fail) { threadUnexpectedException(fail); }
117 }
118
119 try {
120 a.get(randomExpiredTimeout(), randomTimeUnit());
121 shouldThrow();
122 } catch (TimeoutException success) {
123 } catch (Throwable fail) { threadUnexpectedException(fail); }
124 }
125
126 void checkCompletedNormally(ForkJoinTask a) {
127 assertTrue(a.isDone());
128 assertFalse(a.isCancelled());
129 assertTrue(a.isCompletedNormally());
130 assertFalse(a.isCompletedAbnormally());
131 assertNull(a.getException());
132 assertNull(a.getRawResult());
133 assertNull(a.join());
134 assertFalse(a.cancel(false));
135 assertFalse(a.cancel(true));
136
137 Object v1 = null, v2 = null;
138 try {
139 v1 = a.get();
140 v2 = a.get(randomTimeout(), randomTimeUnit());
141 } catch (Throwable fail) { threadUnexpectedException(fail); }
142 assertNull(v1);
143 assertNull(v2);
144 }
145
146 void checkCancelled(ForkJoinTask a) {
147 assertTrue(a.isDone());
148 assertTrue(a.isCancelled());
149 assertFalse(a.isCompletedNormally());
150 assertTrue(a.isCompletedAbnormally());
151 assertTrue(a.getException() instanceof CancellationException);
152 assertNull(a.getRawResult());
153
154 try {
155 a.join();
156 shouldThrow();
157 } catch (CancellationException success) {
158 } catch (Throwable fail) { threadUnexpectedException(fail); }
159
160 try {
161 a.get();
162 shouldThrow();
163 } catch (CancellationException success) {
|