457 |
|
done.await(); |
458 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
459 |
|
}}); |
460 |
< |
assertTrue(threadsStarted.await(SMALL_DELAY_MS, MILLISECONDS)); |
460 |
> |
assertTrue(threadsStarted.await(MEDIUM_DELAY_MS, MILLISECONDS)); |
461 |
|
assertEquals(THREADS, p.getLargestPoolSize()); |
462 |
|
} finally { |
463 |
|
done.countDown(); |
1260 |
|
l.add(new StringTask()); |
1261 |
|
l.add(new StringTask()); |
1262 |
|
List<Future<String>> futures = |
1263 |
< |
e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS); |
1263 |
> |
e.invokeAll(l, LONG_DELAY_MS, MILLISECONDS); |
1264 |
|
assertEquals(2, futures.size()); |
1265 |
|
for (Future<String> future : futures) |
1266 |
|
assertSame(TEST_STRING, future.get()); |