402 |
|
done.await(); |
403 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
404 |
|
}}); |
405 |
< |
assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
405 |
> |
assertTrue(threadsStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
406 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
407 |
|
} finally { |
408 |
|
done.countDown(); |
1207 |
|
l.add(new StringTask()); |
1208 |
|
l.add(new StringTask()); |
1209 |
|
List<Future<String>> futures = |
1210 |
< |
e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS); |
1210 |
> |
e.invokeAll(l, LONG_DELAY_MS, MILLISECONDS); |
1211 |
|
assertEquals(2, futures.size()); |
1212 |
|
for (Future<String> future : futures) |
1213 |
|
assertSame(TEST_STRING, future.get()); |