427 |
|
* getRejectedExecutionHandler returns handler in constructor if not set |
428 |
|
*/ |
429 |
|
public void testGetRejectedExecutionHandler() { |
430 |
< |
final RejectedExecutionHandler h = new NoOpREHandler(); |
430 |
> |
final RejectedExecutionHandler handler = new NoOpREHandler(); |
431 |
|
final ThreadPoolExecutor p = |
432 |
|
new CustomTPE(1, 2, |
433 |
|
LONG_DELAY_MS, MILLISECONDS, |
434 |
|
new ArrayBlockingQueue<Runnable>(10), |
435 |
< |
h); |
435 |
> |
handler); |
436 |
|
try (PoolCleaner cleaner = cleaner(p)) { |
437 |
< |
assertSame(h, p.getRejectedExecutionHandler()); |
437 |
> |
assertSame(handler, p.getRejectedExecutionHandler()); |
438 |
|
} |
439 |
|
} |
440 |
|
|
443 |
|
* getRejectedExecutionHandler |
444 |
|
*/ |
445 |
|
public void testSetRejectedExecutionHandler() { |
446 |
< |
ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10)); |
447 |
< |
RejectedExecutionHandler h = new NoOpREHandler(); |
448 |
< |
p.setRejectedExecutionHandler(h); |
449 |
< |
assertSame(h, p.getRejectedExecutionHandler()); |
450 |
< |
joinPool(p); |
446 |
> |
final ThreadPoolExecutor p = |
447 |
> |
new CustomTPE(1, 2, |
448 |
> |
LONG_DELAY_MS, MILLISECONDS, |
449 |
> |
new ArrayBlockingQueue<Runnable>(10)); |
450 |
> |
try (PoolCleaner cleaner = cleaner(p)) { |
451 |
> |
RejectedExecutionHandler handler = new NoOpREHandler(); |
452 |
> |
p.setRejectedExecutionHandler(handler); |
453 |
> |
assertSame(handler, p.getRejectedExecutionHandler()); |
454 |
> |
} |
455 |
|
} |
456 |
|
|
457 |
|
/** |