2 |
|
* Written by Doug Lea with assistance from members of JCP JSR-166 |
3 |
|
* Expert Group and released to the public domain, as explained at |
4 |
|
* http://creativecommons.org/licenses/publicdomain |
5 |
< |
* Other contributors include Andrew Wright, Jeffrey Hayes, |
6 |
< |
* Pat Fisher, Mike Judd. |
5 |
> |
* Other contributors include Andrew Wright, Jeffrey Hayes, |
6 |
> |
* Pat Fisher, Mike Judd. |
7 |
|
*/ |
8 |
|
|
9 |
|
|
21 |
|
return new TestSuite(AbstractExecutorServiceTest.class); |
22 |
|
} |
23 |
|
|
24 |
< |
/** |
24 |
> |
/** |
25 |
|
* A no-frills implementation of AbstractExecutorService, designed |
26 |
|
* to test the submit methods only. |
27 |
|
*/ |
536 |
|
l.add(new NPETask()); |
537 |
|
List<Future<String>> result = e.invokeAll(l); |
538 |
|
assertEquals(1, result.size()); |
539 |
< |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
539 |
> |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
540 |
|
it.next().get(); |
541 |
|
} catch(ExecutionException success) { |
542 |
|
} catch(Exception ex) { |
557 |
|
l.add(new StringTask()); |
558 |
|
List<Future<String>> result = e.invokeAll(l); |
559 |
|
assertEquals(2, result.size()); |
560 |
< |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
560 |
> |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
561 |
|
assertSame(TEST_STRING, it.next().get()); |
562 |
|
} catch (ExecutionException success) { |
563 |
|
} catch(Exception ex) { |
745 |
|
l.add(new NPETask()); |
746 |
|
List<Future<String>> result = e.invokeAll(l, MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS); |
747 |
|
assertEquals(1, result.size()); |
748 |
< |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
748 |
> |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
749 |
|
it.next().get(); |
750 |
|
} catch(ExecutionException success) { |
751 |
|
} catch(Exception ex) { |
766 |
|
l.add(new StringTask()); |
767 |
|
List<Future<String>> result = e.invokeAll(l, MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS); |
768 |
|
assertEquals(2, result.size()); |
769 |
< |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
769 |
> |
for (Iterator<Future<String>> it = result.iterator(); it.hasNext();) |
770 |
|
assertSame(TEST_STRING, it.next().get()); |
771 |
|
} catch (ExecutionException success) { |
772 |
|
} catch(Exception ex) { |
788 |
|
l.add(new StringTask()); |
789 |
|
List<Future<String>> result = e.invokeAll(l, SMALL_DELAY_MS, TimeUnit.MILLISECONDS); |
790 |
|
assertEquals(3, result.size()); |
791 |
< |
Iterator<Future<String>> it = result.iterator(); |
791 |
> |
Iterator<Future<String>> it = result.iterator(); |
792 |
|
Future<String> f1 = it.next(); |
793 |
|
Future<String> f2 = it.next(); |
794 |
|
Future<String> f3 = it.next(); |