148 |
|
|
149 |
|
} |
150 |
|
|
151 |
< |
static final class AsyncFib extends BinaryAsyncAction { |
151 |
> |
static final class AsyncFib extends BinaryAsyncAction { |
152 |
|
int number; |
153 |
|
public AsyncFib(int n) { |
154 |
|
this.number = n; |
177 |
|
} |
178 |
|
|
179 |
|
|
180 |
< |
static final class FailingAsyncFib extends BinaryAsyncAction { |
180 |
> |
static final class FailingAsyncFib extends BinaryAsyncAction { |
181 |
|
int number; |
182 |
|
public FailingAsyncFib(int n) { |
183 |
|
this.number = n; |
292 |
|
try { |
293 |
|
AsyncFib f = new AsyncFib(8); |
294 |
|
f.fork(); |
295 |
< |
f.get(5L, TimeUnit.SECONDS); |
295 |
> |
f.get(LONG_DELAY_MS, TimeUnit.MILLISECONDS); |
296 |
|
threadAssertTrue(f.number == 21); |
297 |
|
threadAssertTrue(f.isDone()); |
298 |
|
} catch (Exception ex) { |
470 |
|
try { |
471 |
|
FailingAsyncFib f = new FailingAsyncFib(8); |
472 |
|
f.fork(); |
473 |
< |
f.get(5L, TimeUnit.SECONDS); |
473 |
> |
f.get(LONG_DELAY_MS, TimeUnit.MILLISECONDS); |
474 |
|
shouldThrow(); |
475 |
|
} catch (ExecutionException success) { |
476 |
|
} catch (Exception ex) { |
605 |
|
AsyncFib f = new AsyncFib(8); |
606 |
|
f.cancel(true); |
607 |
|
f.fork(); |
608 |
< |
f.get(5L, TimeUnit.SECONDS); |
608 |
> |
f.get(LONG_DELAY_MS, TimeUnit.MILLISECONDS); |
609 |
|
shouldThrow(); |
610 |
|
} catch (CancellationException success) { |
611 |
|
} catch (Exception ex) { |