test/tck/AbstractExecutorServiceTest.java

/*
 * Written by Doug Lea with assistance from members of JCP JSR-166
 * Expert Group and released to the public domain, as explained at
 * http://creativecommons.org/publicdomain/zero/1.0/
 * Other contributors include Andrew Wright, Jeffrey Hayes,
 * Pat Fisher, Mike Judd.
 */

import junit.framework.*;
import java.util.*;
import java.util.concurrent.*;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import java.math.BigInteger;
import java.security.*;

public class AbstractExecutorServiceTest extends JSR166TestCase {
    public static void main(String[] args) {
        junit.textui.TestRunner.run(suite());
    }
    public static Test suite() {
        return new TestSuite(AbstractExecutorServiceTest.class);
    }

    /**
     * A no-frills implementation of AbstractExecutorService, designed
     * to test the submit methods only.
     */
    static class DirectExecutorService extends AbstractExecutorService {
        public void execute(Runnable r) { r.run(); }
        public void shutdown() { shutdown = true; }
        public List<Runnable> shutdownNow() {
            shutdown = true;
            return Collections.EMPTY_LIST;
        }
        public boolean isShutdown() { return shutdown; }
        public boolean isTerminated() { return isShutdown(); }
        public boolean awaitTermination(long timeout, TimeUnit unit) {
            return isShutdown();
        }
        private volatile boolean shutdown = false;
    }

    /**
     * execute(runnable) runs it to completion
     */
    public void testExecuteRunnable() throws Exception {
        ExecutorService e = new DirectExecutorService();
        TrackedShortRunnable task = new TrackedShortRunnable();
        assertFalse(task.done);
        Future<?> future = e.submit(task);
        future.get();
        assertTrue(task.done);
    }

    /**
     * Completed submit(callable) returns result
     */
    public void testSubmitCallable() throws Exception {
        ExecutorService e = new DirectExecutorService();
        Future<String> future = e.submit(new StringTask());
        String result = future.get();
        assertSame(TEST_STRING, result);
    }

    /**
     * Completed submit(runnable) returns successfully
     */
    public void testSubmitRunnable() throws Exception {
        ExecutorService e = new DirectExecutorService();
        Future<?> future = e.submit(new NoOpRunnable());
        future.get();
        assertTrue(future.isDone());
    }

    /**
     * Completed submit(runnable, result) returns result
     */
    public void testSubmitRunnable2() throws Exception {
        ExecutorService e = new DirectExecutorService();
        Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING);
        String result = future.get();
        assertSame(TEST_STRING, result);
    }

    /**
     * A submitted privileged action runs to completion
     */
    public void testSubmitPrivilegedAction() throws Exception {
        Runnable r = new CheckedRunnable() {
            public void realRun() throws Exception {
                ExecutorService e = new DirectExecutorService();
                Future future = e.submit(Executors.callable(new PrivilegedAction() {
                    public Object run() {
                        return TEST_STRING;
                    }}));

                assertSame(TEST_STRING, future.get());
            }};

        runWithPermissions(r,
                           new RuntimePermission("getClassLoader"),
                           new RuntimePermission("setContextClassLoader"),
                           new RuntimePermission("modifyThread"));
    }

    /**
     * A submitted privileged exception action runs to completion
     */
    public void testSubmitPrivilegedExceptionAction() throws Exception {
        Runnable r = new CheckedRunnable() {
            public void realRun() throws Exception {
                ExecutorService e = new DirectExecutorService();
                Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
                    public Object run() {
                        return TEST_STRING;
                    }}));

                assertSame(TEST_STRING, future.get());
            }};

        runWithPermissions(r);
    }

    /**
     * A submitted failed privileged exception action reports exception
     */
    public void testSubmitFailedPrivilegedExceptionAction() throws Exception {
        Runnable r = new CheckedRunnable() {
            public void realRun() throws Exception {
                ExecutorService e = new DirectExecutorService();
                Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
                    public Object run() throws Exception {
                        throw new IndexOutOfBoundsException();
                    }}));

                try {
                    future.get();
                    shouldThrow();
                } catch (ExecutionException success) {
                    assertTrue(success.getCause() instanceof IndexOutOfBoundsException);
                }}};

        runWithPermissions(r);
    }

    /**
     * execute(null runnable) throws NPE
     */
    public void testExecuteNullRunnable() {
        try {
            ExecutorService e = new DirectExecutorService();
            e.submit((Runnable) null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * submit(null callable) throws NPE
     */
    public void testSubmitNullCallable() {
        try {
            ExecutorService e = new DirectExecutorService();
            e.submit((Callable) null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * submit(callable).get() throws InterruptedException if interrupted
     */
    public void testInterruptedSubmit() throws InterruptedException {
        final CountDownLatch submitted    = new CountDownLatch(1);
        final CountDownLatch quittingTime = new CountDownLatch(1);
        final ExecutorService p
            = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS,
                                     new ArrayBlockingQueue<Runnable>(10));
        final Callable<Void> awaiter = new CheckedCallable<Void>() {
            public Void realCall() throws InterruptedException {
                quittingTime.await();
                return null;
            }};
        try {
            Thread t = new Thread(new CheckedInterruptedRunnable() {
                public void realRun() throws Exception {
                    Future<Void> future = p.submit(awaiter);
                    submitted.countDown();
                    future.get();
                }});
            t.start();
            submitted.await();
            t.interrupt();
            t.join();
        } finally {
            quittingTime.countDown();
            joinPool(p);
        }
    }

    /**
     * get of submit(callable) throws ExecutionException if callable
     * throws exception
     */
    public void testSubmitEE() throws InterruptedException {
        ThreadPoolExecutor p =
            new ThreadPoolExecutor(1, 1,
                                   60, TimeUnit.SECONDS,
                                   new ArrayBlockingQueue<Runnable>(10));

        Callable c = new Callable() {
            public Object call() { return 5/0; }};

        try {
            p.submit(c).get();
            shouldThrow();
        } catch (ExecutionException success) {
            assertTrue(success.getCause() instanceof ArithmeticException);
        }
        joinPool(p);
    }

    /**
     * invokeAny(null) throws NPE
     */
    public void testInvokeAny1() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAny(null);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAny(empty collection) throws IAE
     */
    public void testInvokeAny2() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAny(new ArrayList<Callable<String>>());
            shouldThrow();
        } catch (IllegalArgumentException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAny(c) throws NPE if c has null elements
     */
    public void testInvokeAny3() throws Exception {
        ExecutorService e = new DirectExecutorService();
        List<Callable<Integer>> l = new ArrayList<Callable<Integer>>();
        l.add(new Callable<Integer>() {
                  public Integer call() { return 5/0; }});
        l.add(null);
        try {
            e.invokeAny(l);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAny(c) throws ExecutionException if no task in c completes
     */
    public void testInvokeAny4() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new NPETask());
        try {
            e.invokeAny(l);
            shouldThrow();
        } catch (ExecutionException success) {
            assertTrue(success.getCause() instanceof NullPointerException);
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAny(c) returns result of some task in c if at least one completes
     */
    public void testInvokeAny5() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new StringTask());
            l.add(new StringTask());
            String result = e.invokeAny(l);
            assertSame(TEST_STRING, result);
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAll(null) throws NPE
     */
    public void testInvokeAll1() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAll(null);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAll(empty collection) returns empty collection
     */
    public void testInvokeAll2() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Future<String>> r = e.invokeAll(new ArrayList<Callable<String>>());
            assertTrue(r.isEmpty());
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAll(c) throws NPE if c has null elements
     */
    public void testInvokeAll3() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new StringTask());
        l.add(null);
        try {
            e.invokeAll(l);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * get of returned element of invokeAll(c) throws exception on failed task
     */
    public void testInvokeAll4() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new NPETask());
            List<Future<String>> futures = e.invokeAll(l);
            assertEquals(1, futures.size());
            try {
                futures.get(0).get();
                shouldThrow();
            } catch (ExecutionException success) {
                assertTrue(success.getCause() instanceof NullPointerException);
            }
        } finally {
            joinPool(e);
        }
    }

    /**
     * invokeAll(c) returns results of all completed tasks in c
     */
    public void testInvokeAll5() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new StringTask());
            l.add(new StringTask());
            List<Future<String>> futures = e.invokeAll(l);
            assertEquals(2, futures.size());
            for (Future<String> future : futures)
                assertSame(TEST_STRING, future.get());
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(null) throws NPE
     */
    public void testTimedInvokeAny1() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAny(null, MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(null time unit) throws NPE
     */
    public void testTimedInvokeAnyNullTimeUnit() throws Exception {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new StringTask());
        try {
            e.invokeAny(l, MEDIUM_DELAY_MS, null);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(empty collection) throws IAE
     */
    public void testTimedInvokeAny2() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAny(new ArrayList<Callable<String>>(), MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (IllegalArgumentException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(c) throws NPE if c has null elements
     */
    public void testTimedInvokeAny3() throws Exception {
        ExecutorService e = new DirectExecutorService();
        List<Callable<Integer>> l = new ArrayList<Callable<Integer>>();
        l.add(new Callable<Integer>() {
                  public Integer call() { return 5/0; }});
        l.add(null);
        try {
            e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(c) throws ExecutionException if no task completes
     */
    public void testTimedInvokeAny4() throws Exception {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new NPETask());
        try {
            e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (ExecutionException success) {
            assertTrue(success.getCause() instanceof NullPointerException);
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAny(c) returns result of some task in c
     */
    public void testTimedInvokeAny5() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new StringTask());
            l.add(new StringTask());
            String result = e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
            assertSame(TEST_STRING, result);
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll(null) throws NPE
     */
    public void testTimedInvokeAll1() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        try {
            e.invokeAll(null, MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll(null time unit) throws NPE
     */
    public void testTimedInvokeAllNullTimeUnit() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new StringTask());
        try {
            e.invokeAll(l, MEDIUM_DELAY_MS, null);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll(empty collection) returns empty collection
     */
    public void testTimedInvokeAll2() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Future<String>> r = e.invokeAll(new ArrayList<Callable<String>>(), MEDIUM_DELAY_MS, MILLISECONDS);
            assertTrue(r.isEmpty());
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll(c) throws NPE if c has null elements
     */
    public void testTimedInvokeAll3() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        List<Callable<String>> l = new ArrayList<Callable<String>>();
        l.add(new StringTask());
        l.add(null);
        try {
            e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
            shouldThrow();
        } catch (NullPointerException success) {
        } finally {
            joinPool(e);
        }
    }

    /**
     * get of returned element of invokeAll(c) throws exception on failed task
     */
    public void testTimedInvokeAll4() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new NPETask());
            List<Future<String>> futures =
                e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
            assertEquals(1, futures.size());
            try {
                futures.get(0).get();
                shouldThrow();
            } catch (ExecutionException success) {
                assertTrue(success.getCause() instanceof NullPointerException);
            }
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll(c) returns results of all completed tasks in c
     */
    public void testTimedInvokeAll5() throws Exception {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new StringTask());
            l.add(new StringTask());
            List<Future<String>> futures =
                e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
            assertEquals(2, futures.size());
            for (Future<String> future : futures)
                assertSame(TEST_STRING, future.get());
        } finally {
            joinPool(e);
        }
    }

    /**
     * timed invokeAll cancels tasks not completed by timeout
     */
    public void testTimedInvokeAll6() throws InterruptedException {
        ExecutorService e = new DirectExecutorService();
        try {
            List<Callable<String>> l = new ArrayList<Callable<String>>();
            l.add(new StringTask());
            l.add(Executors.callable(possiblyInterruptedRunnable(2 * SHORT_DELAY_MS), TEST_STRING));
            l.add(new StringTask());
            List<Future<String>> futures =
                e.invokeAll(l, SHORT_DELAY_MS, MILLISECONDS);
            assertEquals(3, futures.size());
            Iterator<Future<String>> it = futures.iterator();
            Future<String> f1 = it.next();
            Future<String> f2 = it.next();
            Future<String> f3 = it.next();
            assertTrue(f1.isDone());
            assertFalse(f1.isCancelled());
            assertTrue(f2.isDone());
            assertFalse(f2.isCancelled());
            assertTrue(f3.isDone());
            assertTrue(f3.isCancelled());
        } finally {
            joinPool(e);
        }
    }

}
Revision:	1.31
Committed:	Sat May 28 22:33:35 2011 UTC (12 years, 11 months ago) by jsr166
Branch:	MAIN
Changes since 1.30:	+0 -5 lines
Log Message:	whitespace
#	Content
1	/*
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/publicdomain/zero/1.0/
5	* Other contributors include Andrew Wright, Jeffrey Hayes,
6	* Pat Fisher, Mike Judd.
7	*/
8
9	import junit.framework.*;
10	import java.util.*;
11	import java.util.concurrent.*;
12	import static java.util.concurrent.TimeUnit.MILLISECONDS;
13	import java.math.BigInteger;
14	import java.security.*;
15
16	public class AbstractExecutorServiceTest extends JSR166TestCase {
17	public static void main(String[] args) {
18	junit.textui.TestRunner.run(suite());
19	}
20	public static Test suite() {
21	return new TestSuite(AbstractExecutorServiceTest.class);
22	}
23
24	/**
25	* A no-frills implementation of AbstractExecutorService, designed
26	* to test the submit methods only.
27	*/
28	static class DirectExecutorService extends AbstractExecutorService {
29	public void execute(Runnable r) { r.run(); }
30	public void shutdown() { shutdown = true; }
31	public List<Runnable> shutdownNow() {
32	shutdown = true;
33	return Collections.EMPTY_LIST;
34	}
35	public boolean isShutdown() { return shutdown; }
36	public boolean isTerminated() { return isShutdown(); }
37	public boolean awaitTermination(long timeout, TimeUnit unit) {
38	return isShutdown();
39	}
40	private volatile boolean shutdown = false;
41	}
42
43	/**
44	* execute(runnable) runs it to completion
45	*/
46	public void testExecuteRunnable() throws Exception {
47	ExecutorService e = new DirectExecutorService();
48	TrackedShortRunnable task = new TrackedShortRunnable();
49	assertFalse(task.done);
50	Future<?> future = e.submit(task);
51	future.get();
52	assertTrue(task.done);
53	}
54
55	/**
56	* Completed submit(callable) returns result
57	*/
58	public void testSubmitCallable() throws Exception {
59	ExecutorService e = new DirectExecutorService();
60	Future<String> future = e.submit(new StringTask());
61	String result = future.get();
62	assertSame(TEST_STRING, result);
63	}
64
65	/**
66	* Completed submit(runnable) returns successfully
67	*/
68	public void testSubmitRunnable() throws Exception {
69	ExecutorService e = new DirectExecutorService();
70	Future<?> future = e.submit(new NoOpRunnable());
71	future.get();
72	assertTrue(future.isDone());
73	}
74
75	/**
76	* Completed submit(runnable, result) returns result
77	*/
78	public void testSubmitRunnable2() throws Exception {
79	ExecutorService e = new DirectExecutorService();
80	Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING);
81	String result = future.get();
82	assertSame(TEST_STRING, result);
83	}
84
85	/**
86	* A submitted privileged action runs to completion
87	*/
88	public void testSubmitPrivilegedAction() throws Exception {
89	Runnable r = new CheckedRunnable() {
90	public void realRun() throws Exception {
91	ExecutorService e = new DirectExecutorService();
92	Future future = e.submit(Executors.callable(new PrivilegedAction() {
93	public Object run() {
94	return TEST_STRING;
95	}}));
96
97	assertSame(TEST_STRING, future.get());
98	}};
99
100	runWithPermissions(r,
101	new RuntimePermission("getClassLoader"),
102	new RuntimePermission("setContextClassLoader"),
103	new RuntimePermission("modifyThread"));
104	}
105
106	/**
107	* A submitted privileged exception action runs to completion
108	*/
109	public void testSubmitPrivilegedExceptionAction() throws Exception {
110	Runnable r = new CheckedRunnable() {
111	public void realRun() throws Exception {
112	ExecutorService e = new DirectExecutorService();
113	Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
114	public Object run() {
115	return TEST_STRING;
116	}}));
117
118	assertSame(TEST_STRING, future.get());
119	}};
120
121	runWithPermissions(r);
122	}
123
124	/**
125	* A submitted failed privileged exception action reports exception
126	*/
127	public void testSubmitFailedPrivilegedExceptionAction() throws Exception {
128	Runnable r = new CheckedRunnable() {
129	public void realRun() throws Exception {
130	ExecutorService e = new DirectExecutorService();
131	Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
132	public Object run() throws Exception {
133	throw new IndexOutOfBoundsException();
134	}}));
135
136	try {
137	future.get();
138	shouldThrow();
139	} catch (ExecutionException success) {
140	assertTrue(success.getCause() instanceof IndexOutOfBoundsException);
141	}}};
142
143	runWithPermissions(r);
144	}
145
146	/**
147	* execute(null runnable) throws NPE
148	*/
149	public void testExecuteNullRunnable() {
150	try {
151	ExecutorService e = new DirectExecutorService();
152	e.submit((Runnable) null);
153	shouldThrow();
154	} catch (NullPointerException success) {}
155	}
156
157	/**
158	* submit(null callable) throws NPE
159	*/
160	public void testSubmitNullCallable() {
161	try {
162	ExecutorService e = new DirectExecutorService();
163	e.submit((Callable) null);
164	shouldThrow();
165	} catch (NullPointerException success) {}
166	}
167
168	/**
169	* submit(callable).get() throws InterruptedException if interrupted
170	*/
171	public void testInterruptedSubmit() throws InterruptedException {
172	final CountDownLatch submitted = new CountDownLatch(1);
173	final CountDownLatch quittingTime = new CountDownLatch(1);
174	final ExecutorService p
175	= new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS,
176	new ArrayBlockingQueue<Runnable>(10));
177	final Callable<Void> awaiter = new CheckedCallable<Void>() {
178	public Void realCall() throws InterruptedException {
179	quittingTime.await();
180	return null;
181	}};
182	try {
183	Thread t = new Thread(new CheckedInterruptedRunnable() {
184	public void realRun() throws Exception {
185	Future<Void> future = p.submit(awaiter);
186	submitted.countDown();
187	future.get();
188	}});
189	t.start();
190	submitted.await();
191	t.interrupt();
192	t.join();
193	} finally {
194	quittingTime.countDown();
195	joinPool(p);
196	}
197	}
198
199	/**
200	* get of submit(callable) throws ExecutionException if callable
201	* throws exception
202	*/
203	public void testSubmitEE() throws InterruptedException {
204	ThreadPoolExecutor p =
205	new ThreadPoolExecutor(1, 1,
206	60, TimeUnit.SECONDS,
207	new ArrayBlockingQueue<Runnable>(10));
208
209	Callable c = new Callable() {
210	public Object call() { return 5/0; }};
211
212	try {
213	p.submit(c).get();
214	shouldThrow();
215	} catch (ExecutionException success) {
216	assertTrue(success.getCause() instanceof ArithmeticException);
217	}
218	joinPool(p);
219	}
220
221	/**
222	* invokeAny(null) throws NPE
223	*/
224	public void testInvokeAny1() throws Exception {
225	ExecutorService e = new DirectExecutorService();
226	try {
227	e.invokeAny(null);
228	shouldThrow();
229	} catch (NullPointerException success) {
230	} finally {
231	joinPool(e);
232	}
233	}
234
235	/**
236	* invokeAny(empty collection) throws IAE
237	*/
238	public void testInvokeAny2() throws Exception {
239	ExecutorService e = new DirectExecutorService();
240	try {
241	e.invokeAny(new ArrayList<Callable<String>>());
242	shouldThrow();
243	} catch (IllegalArgumentException success) {
244	} finally {
245	joinPool(e);
246	}
247	}
248
249	/**
250	* invokeAny(c) throws NPE if c has null elements
251	*/
252	public void testInvokeAny3() throws Exception {
253	ExecutorService e = new DirectExecutorService();
254	List<Callable<Integer>> l = new ArrayList<Callable<Integer>>();
255	l.add(new Callable<Integer>() {
256	public Integer call() { return 5/0; }});
257	l.add(null);
258	try {
259	e.invokeAny(l);
260	shouldThrow();
261	} catch (NullPointerException success) {
262	} finally {
263	joinPool(e);
264	}
265	}
266
267	/**
268	* invokeAny(c) throws ExecutionException if no task in c completes
269	*/
270	public void testInvokeAny4() throws InterruptedException {
271	ExecutorService e = new DirectExecutorService();
272	List<Callable<String>> l = new ArrayList<Callable<String>>();
273	l.add(new NPETask());
274	try {
275	e.invokeAny(l);
276	shouldThrow();
277	} catch (ExecutionException success) {
278	assertTrue(success.getCause() instanceof NullPointerException);
279	} finally {
280	joinPool(e);
281	}
282	}
283
284	/**
285	* invokeAny(c) returns result of some task in c if at least one completes
286	*/
287	public void testInvokeAny5() throws Exception {
288	ExecutorService e = new DirectExecutorService();
289	try {
290	List<Callable<String>> l = new ArrayList<Callable<String>>();
291	l.add(new StringTask());
292	l.add(new StringTask());
293	String result = e.invokeAny(l);
294	assertSame(TEST_STRING, result);
295	} finally {
296	joinPool(e);
297	}
298	}
299
300	/**
301	* invokeAll(null) throws NPE
302	*/
303	public void testInvokeAll1() throws InterruptedException {
304	ExecutorService e = new DirectExecutorService();
305	try {
306	e.invokeAll(null);
307	shouldThrow();
308	} catch (NullPointerException success) {
309	} finally {
310	joinPool(e);
311	}
312	}
313
314	/**
315	* invokeAll(empty collection) returns empty collection
316	*/
317	public void testInvokeAll2() throws InterruptedException {
318	ExecutorService e = new DirectExecutorService();
319	try {
320	List<Future<String>> r = e.invokeAll(new ArrayList<Callable<String>>());
321	assertTrue(r.isEmpty());
322	} finally {
323	joinPool(e);
324	}
325	}
326
327	/**
328	* invokeAll(c) throws NPE if c has null elements
329	*/
330	public void testInvokeAll3() throws InterruptedException {
331	ExecutorService e = new DirectExecutorService();
332	List<Callable<String>> l = new ArrayList<Callable<String>>();
333	l.add(new StringTask());
334	l.add(null);
335	try {
336	e.invokeAll(l);
337	shouldThrow();
338	} catch (NullPointerException success) {
339	} finally {
340	joinPool(e);
341	}
342	}
343
344	/**
345	* get of returned element of invokeAll(c) throws exception on failed task
346	*/
347	public void testInvokeAll4() throws Exception {
348	ExecutorService e = new DirectExecutorService();
349	try {
350	List<Callable<String>> l = new ArrayList<Callable<String>>();
351	l.add(new NPETask());
352	List<Future<String>> futures = e.invokeAll(l);
353	assertEquals(1, futures.size());
354	try {
355	futures.get(0).get();
356	shouldThrow();
357	} catch (ExecutionException success) {
358	assertTrue(success.getCause() instanceof NullPointerException);
359	}
360	} finally {
361	joinPool(e);
362	}
363	}
364
365	/**
366	* invokeAll(c) returns results of all completed tasks in c
367	*/
368	public void testInvokeAll5() throws Exception {
369	ExecutorService e = new DirectExecutorService();
370	try {
371	List<Callable<String>> l = new ArrayList<Callable<String>>();
372	l.add(new StringTask());
373	l.add(new StringTask());
374	List<Future<String>> futures = e.invokeAll(l);
375	assertEquals(2, futures.size());
376	for (Future<String> future : futures)
377	assertSame(TEST_STRING, future.get());
378	} finally {
379	joinPool(e);
380	}
381	}
382
383	/**
384	* timed invokeAny(null) throws NPE
385	*/
386	public void testTimedInvokeAny1() throws Exception {
387	ExecutorService e = new DirectExecutorService();
388	try {
389	e.invokeAny(null, MEDIUM_DELAY_MS, MILLISECONDS);
390	shouldThrow();
391	} catch (NullPointerException success) {
392	} finally {
393	joinPool(e);
394	}
395	}
396
397	/**
398	* timed invokeAny(null time unit) throws NPE
399	*/
400	public void testTimedInvokeAnyNullTimeUnit() throws Exception {
401	ExecutorService e = new DirectExecutorService();
402	List<Callable<String>> l = new ArrayList<Callable<String>>();
403	l.add(new StringTask());
404	try {
405	e.invokeAny(l, MEDIUM_DELAY_MS, null);
406	shouldThrow();
407	} catch (NullPointerException success) {
408	} finally {
409	joinPool(e);
410	}
411	}
412
413	/**
414	* timed invokeAny(empty collection) throws IAE
415	*/
416	public void testTimedInvokeAny2() throws Exception {
417	ExecutorService e = new DirectExecutorService();
418	try {
419	e.invokeAny(new ArrayList<Callable<String>>(), MEDIUM_DELAY_MS, MILLISECONDS);
420	shouldThrow();
421	} catch (IllegalArgumentException success) {
422	} finally {
423	joinPool(e);
424	}
425	}
426
427	/**
428	* timed invokeAny(c) throws NPE if c has null elements
429	*/
430	public void testTimedInvokeAny3() throws Exception {
431	ExecutorService e = new DirectExecutorService();
432	List<Callable<Integer>> l = new ArrayList<Callable<Integer>>();
433	l.add(new Callable<Integer>() {
434	public Integer call() { return 5/0; }});
435	l.add(null);
436	try {
437	e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
438	shouldThrow();
439	} catch (NullPointerException success) {
440	} finally {
441	joinPool(e);
442	}
443	}
444
445	/**
446	* timed invokeAny(c) throws ExecutionException if no task completes
447	*/
448	public void testTimedInvokeAny4() throws Exception {
449	ExecutorService e = new DirectExecutorService();
450	List<Callable<String>> l = new ArrayList<Callable<String>>();
451	l.add(new NPETask());
452	try {
453	e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
454	shouldThrow();
455	} catch (ExecutionException success) {
456	assertTrue(success.getCause() instanceof NullPointerException);
457	} finally {
458	joinPool(e);
459	}
460	}
461
462	/**
463	* timed invokeAny(c) returns result of some task in c
464	*/
465	public void testTimedInvokeAny5() throws Exception {
466	ExecutorService e = new DirectExecutorService();
467	try {
468	List<Callable<String>> l = new ArrayList<Callable<String>>();
469	l.add(new StringTask());
470	l.add(new StringTask());
471	String result = e.invokeAny(l, MEDIUM_DELAY_MS, MILLISECONDS);
472	assertSame(TEST_STRING, result);
473	} finally {
474	joinPool(e);
475	}
476	}
477
478	/**
479	* timed invokeAll(null) throws NPE
480	*/
481	public void testTimedInvokeAll1() throws InterruptedException {
482	ExecutorService e = new DirectExecutorService();
483	try {
484	e.invokeAll(null, MEDIUM_DELAY_MS, MILLISECONDS);
485	shouldThrow();
486	} catch (NullPointerException success) {
487	} finally {
488	joinPool(e);
489	}
490	}
491
492	/**
493	* timed invokeAll(null time unit) throws NPE
494	*/
495	public void testTimedInvokeAllNullTimeUnit() throws InterruptedException {
496	ExecutorService e = new DirectExecutorService();
497	List<Callable<String>> l = new ArrayList<Callable<String>>();
498	l.add(new StringTask());
499	try {
500	e.invokeAll(l, MEDIUM_DELAY_MS, null);
501	shouldThrow();
502	} catch (NullPointerException success) {
503	} finally {
504	joinPool(e);
505	}
506	}
507
508	/**
509	* timed invokeAll(empty collection) returns empty collection
510	*/
511	public void testTimedInvokeAll2() throws InterruptedException {
512	ExecutorService e = new DirectExecutorService();
513	try {
514	List<Future<String>> r = e.invokeAll(new ArrayList<Callable<String>>(), MEDIUM_DELAY_MS, MILLISECONDS);
515	assertTrue(r.isEmpty());
516	} finally {
517	joinPool(e);
518	}
519	}
520
521	/**
522	* timed invokeAll(c) throws NPE if c has null elements
523	*/
524	public void testTimedInvokeAll3() throws InterruptedException {
525	ExecutorService e = new DirectExecutorService();
526	List<Callable<String>> l = new ArrayList<Callable<String>>();
527	l.add(new StringTask());
528	l.add(null);
529	try {
530	e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
531	shouldThrow();
532	} catch (NullPointerException success) {
533	} finally {
534	joinPool(e);
535	}
536	}
537
538	/**
539	* get of returned element of invokeAll(c) throws exception on failed task
540	*/
541	public void testTimedInvokeAll4() throws Exception {
542	ExecutorService e = new DirectExecutorService();
543	try {
544	List<Callable<String>> l = new ArrayList<Callable<String>>();
545	l.add(new NPETask());
546	List<Future<String>> futures =
547	e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
548	assertEquals(1, futures.size());
549	try {
550	futures.get(0).get();
551	shouldThrow();
552	} catch (ExecutionException success) {
553	assertTrue(success.getCause() instanceof NullPointerException);
554	}
555	} finally {
556	joinPool(e);
557	}
558	}
559
560	/**
561	* timed invokeAll(c) returns results of all completed tasks in c
562	*/
563	public void testTimedInvokeAll5() throws Exception {
564	ExecutorService e = new DirectExecutorService();
565	try {
566	List<Callable<String>> l = new ArrayList<Callable<String>>();
567	l.add(new StringTask());
568	l.add(new StringTask());
569	List<Future<String>> futures =
570	e.invokeAll(l, MEDIUM_DELAY_MS, MILLISECONDS);
571	assertEquals(2, futures.size());
572	for (Future<String> future : futures)
573	assertSame(TEST_STRING, future.get());
574	} finally {
575	joinPool(e);
576	}
577	}
578
579	/**
580	* timed invokeAll cancels tasks not completed by timeout
581	*/
582	public void testTimedInvokeAll6() throws InterruptedException {
583	ExecutorService e = new DirectExecutorService();
584	try {
585	List<Callable<String>> l = new ArrayList<Callable<String>>();
586	l.add(new StringTask());
587	l.add(Executors.callable(possiblyInterruptedRunnable(2 * SHORT_DELAY_MS), TEST_STRING));
588	l.add(new StringTask());
589	List<Future<String>> futures =
590	e.invokeAll(l, SHORT_DELAY_MS, MILLISECONDS);
591	assertEquals(3, futures.size());
592	Iterator<Future<String>> it = futures.iterator();
593	Future<String> f1 = it.next();
594	Future<String> f2 = it.next();
595	Future<String> f3 = it.next();
596	assertTrue(f1.isDone());
597	assertFalse(f1.isCancelled());
598	assertTrue(f2.isDone());
599	assertFalse(f2.isCancelled());
600	assertTrue(f3.isDone());
601	assertTrue(f3.isCancelled());
602	} finally {
603	joinPool(e);
604	}
605	}
606
607	}