| 6 |
|
* Pat Fisher, Mike Judd. |
| 7 |
|
*/ |
| 8 |
|
|
| 9 |
– |
import java.util.concurrent.*; |
| 9 |
|
import static java.util.concurrent.TimeUnit.MILLISECONDS; |
| 10 |
< |
import java.util.concurrent.atomic.*; |
| 11 |
< |
import junit.framework.*; |
| 12 |
< |
import java.util.*; |
| 10 |
> |
import static java.util.concurrent.TimeUnit.NANOSECONDS; |
| 11 |
> |
|
| 12 |
> |
import java.util.ArrayList; |
| 13 |
> |
import java.util.List; |
| 14 |
> |
import java.util.concurrent.ArrayBlockingQueue; |
| 15 |
> |
import java.util.concurrent.BlockingQueue; |
| 16 |
> |
import java.util.concurrent.Callable; |
| 17 |
> |
import java.util.concurrent.CountDownLatch; |
| 18 |
> |
import java.util.concurrent.ExecutionException; |
| 19 |
> |
import java.util.concurrent.Executors; |
| 20 |
> |
import java.util.concurrent.ExecutorService; |
| 21 |
> |
import java.util.concurrent.Future; |
| 22 |
> |
import java.util.concurrent.FutureTask; |
| 23 |
> |
import java.util.concurrent.LinkedBlockingQueue; |
| 24 |
> |
import java.util.concurrent.RejectedExecutionException; |
| 25 |
> |
import java.util.concurrent.RejectedExecutionHandler; |
| 26 |
> |
import java.util.concurrent.SynchronousQueue; |
| 27 |
> |
import java.util.concurrent.ThreadFactory; |
| 28 |
> |
import java.util.concurrent.ThreadPoolExecutor; |
| 29 |
> |
import java.util.concurrent.TimeUnit; |
| 30 |
> |
|
| 31 |
> |
import junit.framework.Test; |
| 32 |
> |
import junit.framework.TestSuite; |
| 33 |
|
|
| 34 |
|
public class ThreadPoolExecutorTest extends JSR166TestCase { |
| 35 |
|
public static void main(String[] args) { |
| 421 |
|
} |
| 422 |
|
|
| 423 |
|
/** |
| 424 |
+ |
* awaitTermination on a non-shutdown pool times out |
| 425 |
+ |
*/ |
| 426 |
+ |
public void testAwaitTermination_timesOut() throws InterruptedException { |
| 427 |
+ |
final ThreadPoolExecutor p = |
| 428 |
+ |
new ThreadPoolExecutor(1, 1, |
| 429 |
+ |
LONG_DELAY_MS, MILLISECONDS, |
| 430 |
+ |
new ArrayBlockingQueue<Runnable>(10)); |
| 431 |
+ |
assertFalse(p.isTerminated()); |
| 432 |
+ |
assertFalse(p.awaitTermination(Long.MIN_VALUE, NANOSECONDS)); |
| 433 |
+ |
assertFalse(p.awaitTermination(Long.MIN_VALUE, MILLISECONDS)); |
| 434 |
+ |
assertFalse(p.awaitTermination(-1L, NANOSECONDS)); |
| 435 |
+ |
assertFalse(p.awaitTermination(-1L, MILLISECONDS)); |
| 436 |
+ |
assertFalse(p.awaitTermination(0L, NANOSECONDS)); |
| 437 |
+ |
assertFalse(p.awaitTermination(0L, MILLISECONDS)); |
| 438 |
+ |
long timeoutNanos = 999999L; |
| 439 |
+ |
long startTime = System.nanoTime(); |
| 440 |
+ |
assertFalse(p.awaitTermination(timeoutNanos, NANOSECONDS)); |
| 441 |
+ |
assertTrue(System.nanoTime() - startTime >= timeoutNanos); |
| 442 |
+ |
assertFalse(p.isTerminated()); |
| 443 |
+ |
startTime = System.nanoTime(); |
| 444 |
+ |
long timeoutMillis = timeoutMillis(); |
| 445 |
+ |
assertFalse(p.awaitTermination(timeoutMillis, MILLISECONDS)); |
| 446 |
+ |
assertTrue(millisElapsedSince(startTime) >= timeoutMillis); |
| 447 |
+ |
assertFalse(p.isTerminated()); |
| 448 |
+ |
p.shutdown(); |
| 449 |
+ |
assertTrue(p.awaitTermination(LONG_DELAY_MS, MILLISECONDS)); |
| 450 |
+ |
assertTrue(p.isTerminated()); |
| 451 |
+ |
} |
| 452 |
+ |
|
| 453 |
+ |
/** |
| 454 |
|
* isTerminated is false before termination, true after |
| 455 |
|
*/ |
| 456 |
|
public void testIsTerminated() throws InterruptedException { |
| 1394 |
|
ExtendedTPE p = new ExtendedTPE(); |
| 1395 |
|
try { |
| 1396 |
|
final CountDownLatch done = new CountDownLatch(1); |
| 1397 |
< |
final CheckedRunnable task = new CheckedRunnable() { |
| 1397 |
> |
p.execute(new CheckedRunnable() { |
| 1398 |
|
public void realRun() { |
| 1399 |
|
done.countDown(); |
| 1400 |
< |
}}; |
| 1352 |
< |
p.execute(task); |
| 1400 |
> |
}}); |
| 1401 |
|
await(p.afterCalled); |
| 1402 |
|
assertEquals(0, done.getCount()); |
| 1403 |
|
assertTrue(p.afterCalled()); |
