test/tck/ExecutorsTest.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/licenses/publicdomain
 * Other contributors include Andrew Wright, Jeffrey Hayes,
 * Pat Fisher, Mike Judd.
 */


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

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

    static class TimedCallable<T> implements Callable<T> {
        private final ExecutorService exec;
        private final Callable<T> func;
        private final long msecs;

        TimedCallable(ExecutorService exec, Callable<T> func, long msecs) {
            this.exec = exec;
            this.func = func;
            this.msecs = msecs;
        }

        public T call() throws Exception {
            Future<T> ftask = exec.submit(func);
            try {
                return ftask.get(msecs, TimeUnit.MILLISECONDS);
            } finally {
                ftask.cancel(true);
            }
        }
    }


    private static class Fib implements Callable<BigInteger> {
        private final BigInteger n;
        Fib(long n) {
            if (n < 0) throw new IllegalArgumentException("need non-negative arg, but got " + n);
            this.n = BigInteger.valueOf(n);
        }
        public BigInteger call() {
            BigInteger f1 = BigInteger.ONE;
            BigInteger f2 = f1;
            for (BigInteger i = BigInteger.ZERO; i.compareTo(n) < 0; i = i.add(BigInteger.ONE)) {
                BigInteger t = f1.add(f2);
                f1 = f2;
                f2 = t;
            }
            return f1;
        }
    };

    /**
     * A newCachedThreadPool can execute runnables
     */
    public void testNewCachedThreadPool1() {
        ExecutorService e = Executors.newCachedThreadPool();
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A newCachedThreadPool with given ThreadFactory can execute runnables
     */
    public void testNewCachedThreadPool2() {
        ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A newCachedThreadPool with null ThreadFactory throws NPE
     */
    public void testNewCachedThreadPool3() {
        try {
            ExecutorService e = Executors.newCachedThreadPool(null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }


    /**
     * A new SingleThreadExecutor can execute runnables
     */
    public void testNewSingleThreadExecutor1() {
        ExecutorService e = Executors.newSingleThreadExecutor();
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A new SingleThreadExecutor with given ThreadFactory can execute runnables
     */
    public void testNewSingleThreadExecutor2() {
        ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A new SingleThreadExecutor with null ThreadFactory throws NPE
     */
    public void testNewSingleThreadExecutor3() {
        try {
            ExecutorService e = Executors.newSingleThreadExecutor(null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * A new SingleThreadExecutor cannot be casted to concrete implementation
     */
    public void testCastNewSingleThreadExecutor() {
        ExecutorService e = Executors.newSingleThreadExecutor();
        try {
            ThreadPoolExecutor tpe = (ThreadPoolExecutor)e;
            shouldThrow();
        } catch (ClassCastException success) {
        } finally {
            joinPool(e);
        }
    }


    /**
     * A new newFixedThreadPool can execute runnables
     */
    public void testNewFixedThreadPool1() {
        ExecutorService e = Executors.newFixedThreadPool(2);
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A new newFixedThreadPool with given ThreadFactory can execute runnables
     */
    public void testNewFixedThreadPool2() {
        ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * A new newFixedThreadPool with null ThreadFactory throws NPE
     */
    public void testNewFixedThreadPool3() {
        try {
            ExecutorService e = Executors.newFixedThreadPool(2, null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * A new newFixedThreadPool with 0 threads throws IAE
     */
    public void testNewFixedThreadPool4() {
        try {
            ExecutorService e = Executors.newFixedThreadPool(0);
            shouldThrow();
        } catch (IllegalArgumentException success) {}
    }


    /**
     * An unconfigurable newFixedThreadPool can execute runnables
     */
    public void testunconfigurableExecutorService() {
        ExecutorService e = Executors.unconfigurableExecutorService(Executors.newFixedThreadPool(2));
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        e.execute(new NoOpRunnable());
        joinPool(e);
    }

    /**
     * unconfigurableExecutorService(null) throws NPE
     */
    public void testunconfigurableExecutorServiceNPE() {
        try {
            ExecutorService e = Executors.unconfigurableExecutorService(null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * unconfigurableScheduledExecutorService(null) throws NPE
     */
    public void testunconfigurableScheduledExecutorServiceNPE() {
        try {
            ExecutorService e = Executors.unconfigurableScheduledExecutorService(null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }


    /**
     * a newSingleThreadScheduledExecutor successfully runs delayed task
     */
    public void testNewSingleThreadScheduledExecutor() throws Exception {
        try {
            TrackedCallable callable = new TrackedCallable();
            ScheduledExecutorService p1 = Executors.newSingleThreadScheduledExecutor();
            Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
            assertFalse(callable.done);
            Thread.sleep(MEDIUM_DELAY_MS);
            assertTrue(callable.done);
            assertEquals(Boolean.TRUE, f.get());
            joinPool(p1);
        } catch (RejectedExecutionException e) {}
    }

    /**
     * a newScheduledThreadPool successfully runs delayed task
     */
    public void testnewScheduledThreadPool() throws Exception {
        try {
            TrackedCallable callable = new TrackedCallable();
            ScheduledExecutorService p1 = Executors.newScheduledThreadPool(2);
            Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
            assertFalse(callable.done);
            Thread.sleep(MEDIUM_DELAY_MS);
            assertTrue(callable.done);
            assertEquals(Boolean.TRUE, f.get());
            joinPool(p1);
        } catch (RejectedExecutionException e) {}
    }

    /**
     * an unconfigurable  newScheduledThreadPool successfully runs delayed task
     */
    public void testunconfigurableScheduledExecutorService() throws Exception {
        try {
            TrackedCallable callable = new TrackedCallable();
            ScheduledExecutorService p1 = Executors.unconfigurableScheduledExecutorService(Executors.newScheduledThreadPool(2));
            Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
            assertFalse(callable.done);
            Thread.sleep(MEDIUM_DELAY_MS);
            assertTrue(callable.done);
            assertEquals(Boolean.TRUE, f.get());
            joinPool(p1);
        } catch (RejectedExecutionException e) {}
    }

    /**
     *  timeouts from execute will time out if they compute too long.
     */
    public void testTimedCallable() throws Exception {
        int N = 10000;
        ExecutorService executor = Executors.newSingleThreadExecutor();
        List<Callable<BigInteger>> tasks = new ArrayList<Callable<BigInteger>>(N);
        try {
            long startTime = System.currentTimeMillis();

            long i = 0;
            while (tasks.size() < N) {
                tasks.add(new TimedCallable<BigInteger>(executor, new Fib(i), 1));
                i += 10;
            }

            int iters = 0;
            BigInteger sum = BigInteger.ZERO;
            for (Iterator<Callable<BigInteger>> it = tasks.iterator(); it.hasNext();) {
                try {
                    ++iters;
                    sum = sum.add(it.next().call());
                }
                catch (TimeoutException success) {
                    assertTrue(iters > 0);
                    return;
                }
            }
            // if by chance we didn't ever time out, total time must be small
            long elapsed = System.currentTimeMillis() - startTime;
            assertTrue(elapsed < N);
        }
        finally {
            joinPool(executor);
        }
    }


    /**
     * ThreadPoolExecutor using defaultThreadFactory has
     * specified group, priority, daemon status, and name
     */
    public void testDefaultThreadFactory() throws Exception {
        final ThreadGroup egroup = Thread.currentThread().getThreadGroup();
        Runnable r = new Runnable() {
                public void run() {
                    try {
                        Thread current = Thread.currentThread();
                        threadAssertTrue(!current.isDaemon());
                        threadAssertTrue(current.getPriority() <= Thread.NORM_PRIORITY);
                        ThreadGroup g = current.getThreadGroup();
                        SecurityManager s = System.getSecurityManager();
                        if (s != null)
                            threadAssertTrue(g == s.getThreadGroup());
                        else
                            threadAssertTrue(g == egroup);
                        String name = current.getName();
                        threadAssertTrue(name.endsWith("thread-1"));
                    } catch (SecurityException ok) {
                        // Also pass if not allowed to change setting
                    }
                }
            };
        ExecutorService e = Executors.newSingleThreadExecutor(Executors.defaultThreadFactory());

        e.execute(r);
        try {
            e.shutdown();
        } catch (SecurityException ok) {
        }

        try {
            Thread.sleep(SHORT_DELAY_MS);
        } finally {
            joinPool(e);
        }
    }

    /**
     * ThreadPoolExecutor using privilegedThreadFactory has
     * specified group, priority, daemon status, name,
     * access control context and context class loader
     */
    public void testPrivilegedThreadFactory() throws Exception {
        Policy savedPolicy = null;
        try {
            savedPolicy = Policy.getPolicy();
            AdjustablePolicy policy = new AdjustablePolicy();
            policy.addPermission(new RuntimePermission("getContextClassLoader"));
            policy.addPermission(new RuntimePermission("setContextClassLoader"));
            Policy.setPolicy(policy);
        } catch (AccessControlException ok) {
            return;
        }
        final ThreadGroup egroup = Thread.currentThread().getThreadGroup();
        final ClassLoader thisccl = Thread.currentThread().getContextClassLoader();
        final AccessControlContext thisacc = AccessController.getContext();
        Runnable r = new Runnable() {
                public void run() {
                    try {
                        Thread current = Thread.currentThread();
                        threadAssertTrue(!current.isDaemon());
                        threadAssertTrue(current.getPriority() <= Thread.NORM_PRIORITY);
                        ThreadGroup g = current.getThreadGroup();
                        SecurityManager s = System.getSecurityManager();
                        if (s != null)
                            threadAssertTrue(g == s.getThreadGroup());
                        else
                            threadAssertTrue(g == egroup);
                        String name = current.getName();
                        threadAssertTrue(name.endsWith("thread-1"));
                        threadAssertTrue(thisccl == current.getContextClassLoader());
                        threadAssertTrue(thisacc.equals(AccessController.getContext()));
                    } catch (SecurityException ok) {
                        // Also pass if not allowed to change settings
                    }
                }
            };
        ExecutorService e = Executors.newSingleThreadExecutor(Executors.privilegedThreadFactory());

        Policy.setPolicy(savedPolicy);
        e.execute(r);
        try {
            e.shutdown();
        } catch (SecurityException ok) {
        }
        try {
            Thread.sleep(SHORT_DELAY_MS);
        } finally {
            joinPool(e);
        }

    }

    void checkCCL() {
        SecurityManager sm = System.getSecurityManager();
        if (sm != null) {
            sm.checkPermission(new RuntimePermission("setContextClassLoader"));
            sm.checkPermission(new RuntimePermission("getClassLoader"));
        }
    }

    class CheckCCL implements Callable<Object> {
        public Object call() {
            checkCCL();
            return null;
        }
    }


    /**
     * Without class loader permissions, creating
     * privilegedCallableUsingCurrentClassLoader throws ACE
     */
    public void testCreatePrivilegedCallableUsingCCLWithNoPrivs() {
        Policy savedPolicy = null;
        try {
            savedPolicy = Policy.getPolicy();
            AdjustablePolicy policy = new AdjustablePolicy();
            Policy.setPolicy(policy);
        } catch (AccessControlException ok) {
            return;
        }

        // Check if program still has too many permissions to run test
        try {
            checkCCL();
            // too many privileges to test; so return
            Policy.setPolicy(savedPolicy);
            return;
        } catch (AccessControlException ok) {
        }

        try {
            Callable task = Executors.privilegedCallableUsingCurrentClassLoader(new NoOpCallable());
            shouldThrow();
        } catch (AccessControlException success) {
        } finally {
            Policy.setPolicy(savedPolicy);
        }
    }

    /**
     * With class loader permissions, calling
     * privilegedCallableUsingCurrentClassLoader does not throw ACE
     */
    public void testprivilegedCallableUsingCCLWithPrivs() throws Exception {
        Policy savedPolicy = null;
        try {
            savedPolicy = Policy.getPolicy();
            AdjustablePolicy policy = new AdjustablePolicy();
            policy.addPermission(new RuntimePermission("getContextClassLoader"));
            policy.addPermission(new RuntimePermission("setContextClassLoader"));
            Policy.setPolicy(policy);
        } catch (AccessControlException ok) {
            return;
        }

        try {
            Callable task = Executors.privilegedCallableUsingCurrentClassLoader(new NoOpCallable());
            task.call();
        }
        finally {
            Policy.setPolicy(savedPolicy);
        }
    }

    /**
     * Without permissions, calling privilegedCallable throws ACE
     */
    public void testprivilegedCallableWithNoPrivs() throws Exception {
        Callable task;
        Policy savedPolicy = null;
        AdjustablePolicy policy = null;
        AccessControlContext noprivAcc = null;
        try {
            savedPolicy = Policy.getPolicy();
            policy = new AdjustablePolicy();
            Policy.setPolicy(policy);
            noprivAcc = AccessController.getContext();
            task = Executors.privilegedCallable(new CheckCCL());
            Policy.setPolicy(savedPolicy);
        } catch (AccessControlException ok) {
            return; // program has too few permissions to set up test
        }

        // Make sure that program doesn't have too many permissions
        try {
            AccessController.doPrivileged(new PrivilegedAction() {
                    public Object run() {
                        checkCCL();
                        return null;
                    }}, noprivAcc);
            // too many permssions; skip test
            return;
        } catch (AccessControlException ok) {
        }

        try {
            task.call();
            shouldThrow();
        } catch (AccessControlException success) {}
    }

    /**
     * With permissions, calling privilegedCallable succeeds
     */
    public void testprivilegedCallableWithPrivs() throws Exception {
        Policy savedPolicy = null;
        try {
            savedPolicy = Policy.getPolicy();
            AdjustablePolicy policy = new AdjustablePolicy();
            policy.addPermission(new RuntimePermission("getContextClassLoader"));
            policy.addPermission(new RuntimePermission("setContextClassLoader"));
            Policy.setPolicy(policy);
        } catch (AccessControlException ok) {
            return;
        }

        Callable task = Executors.privilegedCallable(new CheckCCL());
        try {
            task.call();
        } finally {
            Policy.setPolicy(savedPolicy);
        }
    }

    /**
     * callable(Runnable) returns null when called
     */
    public void testCallable1() throws Exception {
        Callable c = Executors.callable(new NoOpRunnable());
        assertNull(c.call());
    }

    /**
     * callable(Runnable, result) returns result when called
     */
    public void testCallable2() throws Exception {
        Callable c = Executors.callable(new NoOpRunnable(), one);
        assertEquals(one, c.call());
    }

    /**
     * callable(PrivilegedAction) returns its result when called
     */
    public void testCallable3() throws Exception {
        Callable c = Executors.callable(new PrivilegedAction() {
                public Object run() { return one; }});
        assertEquals(one, c.call());
    }

    /**
     * callable(PrivilegedExceptionAction) returns its result when called
     */
    public void testCallable4() throws Exception {
        Callable c = Executors.callable(new PrivilegedExceptionAction() {
                public Object run() { return one; }});
        assertEquals(one, c.call());
    }


    /**
     * callable(null Runnable) throws NPE
     */
    public void testCallableNPE1() {
        try {
            Callable c = Executors.callable((Runnable) null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * callable(null, result) throws NPE
     */
    public void testCallableNPE2() {
        try {
            Callable c = Executors.callable((Runnable) null, one);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * callable(null PrivilegedAction) throws NPE
     */
    public void testCallableNPE3() {
        try {
            Callable c = Executors.callable((PrivilegedAction) null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }

    /**
     * callable(null PrivilegedExceptionAction) throws NPE
     */
    public void testCallableNPE4() {
        try {
            Callable c = Executors.callable((PrivilegedExceptionAction) null);
            shouldThrow();
        } catch (NullPointerException success) {}
    }


}
Revision:	1.23
Committed:	Thu Nov 19 03:55:29 2009 UTC (14 years, 5 months ago) by jsr166
Branch:	MAIN
Changes since 1.22:	+45 -104 lines
Log Message:	better exception handling
#	User	Rev	Content
1	dl	1.1	/*
2	dl	1.12	* 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	jsr166	1.20	* Other contributors include Andrew Wright, Jeffrey Hayes,
6			* Pat Fisher, Mike Judd.
7	dl	1.1	*/
8
9
10			import junit.framework.*;
11			import java.util.*;
12			import java.util.concurrent.*;
13	dl	1.2	import java.math.BigInteger;
14	dl	1.8	import java.security.*;
15	dl	1.1
16	jsr166	1.22	public class ExecutorsTest extends JSR166TestCase {
17	dl	1.1	public static void main(String[] args) {
18	jsr166	1.20	junit.textui.TestRunner.run (suite());
19	dl	1.1	}
20			public static Test suite() {
21	tim	1.9	return new TestSuite(ExecutorsTest.class);
22	dl	1.1	}
23
24	dl	1.4	static class TimedCallable<T> implements Callable<T> {
25	tim	1.10	private final ExecutorService exec;
26	dl	1.4	private final Callable<T> func;
27			private final long msecs;
28	jsr166	1.20
29	tim	1.10	TimedCallable(ExecutorService exec, Callable<T> func, long msecs) {
30	dl	1.4	this.exec = exec;
31			this.func = func;
32			this.msecs = msecs;
33			}
34	jsr166	1.20
35	dl	1.4	public T call() throws Exception {
36	tim	1.10	Future<T> ftask = exec.submit(func);
37	dl	1.4	try {
38			return ftask.get(msecs, TimeUnit.MILLISECONDS);
39			} finally {
40			ftask.cancel(true);
41			}
42			}
43			}
44
45
46			private static class Fib implements Callable<BigInteger> {
47			private final BigInteger n;
48			Fib(long n) {
49			if (n < 0) throw new IllegalArgumentException("need non-negative arg, but got " + n);
50			this.n = BigInteger.valueOf(n);
51			}
52			public BigInteger call() {
53			BigInteger f1 = BigInteger.ONE;
54			BigInteger f2 = f1;
55			for (BigInteger i = BigInteger.ZERO; i.compareTo(n) < 0; i = i.add(BigInteger.ONE)) {
56			BigInteger t = f1.add(f2);
57			f1 = f2;
58			f2 = t;
59			}
60			return f1;
61			}
62			};
63
64	dl	1.5	/**
65			* A newCachedThreadPool can execute runnables
66			*/
67			public void testNewCachedThreadPool1() {
68			ExecutorService e = Executors.newCachedThreadPool();
69			e.execute(new NoOpRunnable());
70			e.execute(new NoOpRunnable());
71			e.execute(new NoOpRunnable());
72	dl	1.14	joinPool(e);
73	dl	1.5	}
74
75			/**
76			* A newCachedThreadPool with given ThreadFactory can execute runnables
77			*/
78			public void testNewCachedThreadPool2() {
79	dl	1.6	ExecutorService e = Executors.newCachedThreadPool(new SimpleThreadFactory());
80	dl	1.5	e.execute(new NoOpRunnable());
81			e.execute(new NoOpRunnable());
82			e.execute(new NoOpRunnable());
83	dl	1.14	joinPool(e);
84	dl	1.5	}
85
86			/**
87			* A newCachedThreadPool with null ThreadFactory throws NPE
88			*/
89			public void testNewCachedThreadPool3() {
90			try {
91			ExecutorService e = Executors.newCachedThreadPool(null);
92			shouldThrow();
93	jsr166	1.23	} catch (NullPointerException success) {}
94	dl	1.5	}
95
96
97			/**
98			* A new SingleThreadExecutor can execute runnables
99			*/
100			public void testNewSingleThreadExecutor1() {
101			ExecutorService e = Executors.newSingleThreadExecutor();
102			e.execute(new NoOpRunnable());
103			e.execute(new NoOpRunnable());
104			e.execute(new NoOpRunnable());
105	dl	1.14	joinPool(e);
106	dl	1.5	}
107
108			/**
109			* A new SingleThreadExecutor with given ThreadFactory can execute runnables
110			*/
111			public void testNewSingleThreadExecutor2() {
112	dl	1.6	ExecutorService e = Executors.newSingleThreadExecutor(new SimpleThreadFactory());
113	dl	1.5	e.execute(new NoOpRunnable());
114			e.execute(new NoOpRunnable());
115			e.execute(new NoOpRunnable());
116	dl	1.14	joinPool(e);
117	dl	1.5	}
118
119			/**
120			* A new SingleThreadExecutor with null ThreadFactory throws NPE
121			*/
122			public void testNewSingleThreadExecutor3() {
123			try {
124			ExecutorService e = Executors.newSingleThreadExecutor(null);
125			shouldThrow();
126	jsr166	1.23	} catch (NullPointerException success) {}
127	dl	1.5	}
128
129			/**
130	dl	1.11	* A new SingleThreadExecutor cannot be casted to concrete implementation
131			*/
132			public void testCastNewSingleThreadExecutor() {
133			ExecutorService e = Executors.newSingleThreadExecutor();
134			try {
135			ThreadPoolExecutor tpe = (ThreadPoolExecutor)e;
136	jsr166	1.23	shouldThrow();
137	dl	1.11	} catch (ClassCastException success) {
138			} finally {
139			joinPool(e);
140			}
141			}
142
143
144			/**
145	dl	1.5	* A new newFixedThreadPool can execute runnables
146			*/
147			public void testNewFixedThreadPool1() {
148			ExecutorService e = Executors.newFixedThreadPool(2);
149			e.execute(new NoOpRunnable());
150			e.execute(new NoOpRunnable());
151			e.execute(new NoOpRunnable());
152	dl	1.14	joinPool(e);
153	dl	1.5	}
154
155			/**
156			* A new newFixedThreadPool with given ThreadFactory can execute runnables
157			*/
158			public void testNewFixedThreadPool2() {
159	dl	1.6	ExecutorService e = Executors.newFixedThreadPool(2, new SimpleThreadFactory());
160	dl	1.5	e.execute(new NoOpRunnable());
161			e.execute(new NoOpRunnable());
162			e.execute(new NoOpRunnable());
163	dl	1.14	joinPool(e);
164	dl	1.5	}
165
166			/**
167			* A new newFixedThreadPool with null ThreadFactory throws NPE
168			*/
169			public void testNewFixedThreadPool3() {
170			try {
171			ExecutorService e = Executors.newFixedThreadPool(2, null);
172			shouldThrow();
173	jsr166	1.23	} catch (NullPointerException success) {}
174	dl	1.5	}
175
176			/**
177			* A new newFixedThreadPool with 0 threads throws IAE
178			*/
179			public void testNewFixedThreadPool4() {
180			try {
181			ExecutorService e = Executors.newFixedThreadPool(0);
182			shouldThrow();
183	jsr166	1.23	} catch (IllegalArgumentException success) {}
184	dl	1.5	}
185	dl	1.1
186	dl	1.2
187			/**
188	dl	1.11	* An unconfigurable newFixedThreadPool can execute runnables
189			*/
190			public void testunconfigurableExecutorService() {
191			ExecutorService e = Executors.unconfigurableExecutorService(Executors.newFixedThreadPool(2));
192			e.execute(new NoOpRunnable());
193			e.execute(new NoOpRunnable());
194			e.execute(new NoOpRunnable());
195	dl	1.14	joinPool(e);
196	dl	1.11	}
197
198			/**
199			* unconfigurableExecutorService(null) throws NPE
200			*/
201			public void testunconfigurableExecutorServiceNPE() {
202			try {
203			ExecutorService e = Executors.unconfigurableExecutorService(null);
204	jsr166	1.23	shouldThrow();
205			} catch (NullPointerException success) {}
206	dl	1.11	}
207
208			/**
209			* unconfigurableScheduledExecutorService(null) throws NPE
210			*/
211			public void testunconfigurableScheduledExecutorServiceNPE() {
212			try {
213			ExecutorService e = Executors.unconfigurableScheduledExecutorService(null);
214	jsr166	1.23	shouldThrow();
215			} catch (NullPointerException success) {}
216	dl	1.11	}
217
218
219			/**
220			* a newSingleThreadScheduledExecutor successfully runs delayed task
221			*/
222	jsr166	1.23	public void testNewSingleThreadScheduledExecutor() throws Exception {
223	dl	1.11	try {
224			TrackedCallable callable = new TrackedCallable();
225			ScheduledExecutorService p1 = Executors.newSingleThreadScheduledExecutor();
226			Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
227			assertFalse(callable.done);
228			Thread.sleep(MEDIUM_DELAY_MS);
229			assertTrue(callable.done);
230			assertEquals(Boolean.TRUE, f.get());
231			joinPool(p1);
232	jsr166	1.22	} catch (RejectedExecutionException e) {}
233	dl	1.11	}
234
235			/**
236			* a newScheduledThreadPool successfully runs delayed task
237			*/
238	jsr166	1.23	public void testnewScheduledThreadPool() throws Exception {
239	dl	1.11	try {
240			TrackedCallable callable = new TrackedCallable();
241			ScheduledExecutorService p1 = Executors.newScheduledThreadPool(2);
242			Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
243			assertFalse(callable.done);
244			Thread.sleep(MEDIUM_DELAY_MS);
245			assertTrue(callable.done);
246			assertEquals(Boolean.TRUE, f.get());
247			joinPool(p1);
248	jsr166	1.22	} catch (RejectedExecutionException e) {}
249	dl	1.11	}
250
251			/**
252			* an unconfigurable newScheduledThreadPool successfully runs delayed task
253			*/
254	jsr166	1.23	public void testunconfigurableScheduledExecutorService() throws Exception {
255	dl	1.11	try {
256			TrackedCallable callable = new TrackedCallable();
257			ScheduledExecutorService p1 = Executors.unconfigurableScheduledExecutorService(Executors.newScheduledThreadPool(2));
258			Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
259			assertFalse(callable.done);
260			Thread.sleep(MEDIUM_DELAY_MS);
261			assertTrue(callable.done);
262			assertEquals(Boolean.TRUE, f.get());
263			joinPool(p1);
264	jsr166	1.22	} catch (RejectedExecutionException e) {}
265	dl	1.11	}
266
267			/**
268	dl	1.4	* timeouts from execute will time out if they compute too long.
269	dl	1.2	*/
270	jsr166	1.23	public void testTimedCallable() throws Exception {
271	dl	1.2	int N = 10000;
272			ExecutorService executor = Executors.newSingleThreadExecutor();
273			List<Callable<BigInteger>> tasks = new ArrayList<Callable<BigInteger>>(N);
274			try {
275			long startTime = System.currentTimeMillis();
276	jsr166	1.20
277	dl	1.2	long i = 0;
278			while (tasks.size() < N) {
279			tasks.add(new TimedCallable<BigInteger>(executor, new Fib(i), 1));
280			i += 10;
281			}
282	jsr166	1.20
283	dl	1.2	int iters = 0;
284			BigInteger sum = BigInteger.ZERO;
285			for (Iterator<Callable<BigInteger>> it = tasks.iterator(); it.hasNext();) {
286			try {
287			++iters;
288			sum = sum.add(it.next().call());
289			}
290			catch (TimeoutException success) {
291			assertTrue(iters > 0);
292			return;
293			}
294			}
295			// if by chance we didn't ever time out, total time must be small
296			long elapsed = System.currentTimeMillis() - startTime;
297			assertTrue(elapsed < N);
298			}
299			finally {
300	dl	1.3	joinPool(executor);
301	dl	1.2	}
302			}
303
304	jsr166	1.20
305	dl	1.8	/**
306			* ThreadPoolExecutor using defaultThreadFactory has
307			* specified group, priority, daemon status, and name
308			*/
309	jsr166	1.23	public void testDefaultThreadFactory() throws Exception {
310	tim	1.9	final ThreadGroup egroup = Thread.currentThread().getThreadGroup();
311			Runnable r = new Runnable() {
312			public void run() {
313	dl	1.13	try {
314			Thread current = Thread.currentThread();
315			threadAssertTrue(!current.isDaemon());
316	dl	1.17	threadAssertTrue(current.getPriority() <= Thread.NORM_PRIORITY);
317	dl	1.13	ThreadGroup g = current.getThreadGroup();
318			SecurityManager s = System.getSecurityManager();
319			if (s != null)
320			threadAssertTrue(g == s.getThreadGroup());
321			else
322			threadAssertTrue(g == egroup);
323			String name = current.getName();
324			threadAssertTrue(name.endsWith("thread-1"));
325			} catch (SecurityException ok) {
326			// Also pass if not allowed to change setting
327			}
328	tim	1.9	}
329			};
330			ExecutorService e = Executors.newSingleThreadExecutor(Executors.defaultThreadFactory());
331	jsr166	1.20
332	tim	1.9	e.execute(r);
333	dl	1.14	try {
334			e.shutdown();
335	jsr166	1.21	} catch (SecurityException ok) {
336	dl	1.14	}
337	jsr166	1.20
338	tim	1.9	try {
339			Thread.sleep(SHORT_DELAY_MS);
340			} finally {
341			joinPool(e);
342			}
343	dl	1.8	}
344
345			/**
346			* ThreadPoolExecutor using privilegedThreadFactory has
347			* specified group, priority, daemon status, name,
348			* access control context and context class loader
349			*/
350	jsr166	1.23	public void testPrivilegedThreadFactory() throws Exception {
351	dl	1.14	Policy savedPolicy = null;
352			try {
353			savedPolicy = Policy.getPolicy();
354			AdjustablePolicy policy = new AdjustablePolicy();
355			policy.addPermission(new RuntimePermission("getContextClassLoader"));
356			policy.addPermission(new RuntimePermission("setContextClassLoader"));
357			Policy.setPolicy(policy);
358			} catch (AccessControlException ok) {
359			return;
360			}
361	tim	1.9	final ThreadGroup egroup = Thread.currentThread().getThreadGroup();
362			final ClassLoader thisccl = Thread.currentThread().getContextClassLoader();
363	dl	1.8	final AccessControlContext thisacc = AccessController.getContext();
364	tim	1.9	Runnable r = new Runnable() {
365			public void run() {
366	dl	1.13	try {
367			Thread current = Thread.currentThread();
368			threadAssertTrue(!current.isDaemon());
369	dl	1.17	threadAssertTrue(current.getPriority() <= Thread.NORM_PRIORITY);
370	dl	1.13	ThreadGroup g = current.getThreadGroup();
371			SecurityManager s = System.getSecurityManager();
372			if (s != null)
373			threadAssertTrue(g == s.getThreadGroup());
374			else
375			threadAssertTrue(g == egroup);
376			String name = current.getName();
377			threadAssertTrue(name.endsWith("thread-1"));
378			threadAssertTrue(thisccl == current.getContextClassLoader());
379			threadAssertTrue(thisacc.equals(AccessController.getContext()));
380	jsr166	1.21	} catch (SecurityException ok) {
381	dl	1.13	// Also pass if not allowed to change settings
382			}
383	dl	1.14	}
384	tim	1.9	};
385			ExecutorService e = Executors.newSingleThreadExecutor(Executors.privilegedThreadFactory());
386	jsr166	1.20
387	tim	1.9	Policy.setPolicy(savedPolicy);
388			e.execute(r);
389	dl	1.14	try {
390			e.shutdown();
391	jsr166	1.21	} catch (SecurityException ok) {
392	dl	1.14	}
393	tim	1.9	try {
394			Thread.sleep(SHORT_DELAY_MS);
395			} finally {
396			joinPool(e);
397			}
398	dl	1.1
399	dl	1.8	}
400	dl	1.11
401	dl	1.16	void checkCCL() {
402	dl	1.18	SecurityManager sm = System.getSecurityManager();
403			if (sm != null) {
404			sm.checkPermission(new RuntimePermission("setContextClassLoader"));
405	jsr166	1.19	sm.checkPermission(new RuntimePermission("getClassLoader"));
406	dl	1.18	}
407	dl	1.16	}
408
409			class CheckCCL implements Callable<Object> {
410	dl	1.11	public Object call() {
411	dl	1.16	checkCCL();
412	dl	1.11	return null;
413			}
414			}
415
416
417			/**
418			* Without class loader permissions, creating
419			* privilegedCallableUsingCurrentClassLoader throws ACE
420			*/
421			public void testCreatePrivilegedCallableUsingCCLWithNoPrivs() {
422	dl	1.14	Policy savedPolicy = null;
423			try {
424			savedPolicy = Policy.getPolicy();
425			AdjustablePolicy policy = new AdjustablePolicy();
426			Policy.setPolicy(policy);
427			} catch (AccessControlException ok) {
428			return;
429			}
430
431	dl	1.16	// Check if program still has too many permissions to run test
432			try {
433			checkCCL();
434			// too many privileges to test; so return
435			Policy.setPolicy(savedPolicy);
436			return;
437	jsr166	1.21	} catch (AccessControlException ok) {
438	jsr166	1.20	}
439	dl	1.16
440	dl	1.11	try {
441			Callable task = Executors.privilegedCallableUsingCurrentClassLoader(new NoOpCallable());
442			shouldThrow();
443	jsr166	1.21	} catch (AccessControlException success) {
444	jsr166	1.23	} finally {
445	dl	1.11	Policy.setPolicy(savedPolicy);
446			}
447			}
448
449			/**
450	dl	1.16	* With class loader permissions, calling
451			* privilegedCallableUsingCurrentClassLoader does not throw ACE
452	dl	1.11	*/
453	jsr166	1.23	public void testprivilegedCallableUsingCCLWithPrivs() throws Exception {
454	dl	1.14	Policy savedPolicy = null;
455			try {
456			savedPolicy = Policy.getPolicy();
457			AdjustablePolicy policy = new AdjustablePolicy();
458			policy.addPermission(new RuntimePermission("getContextClassLoader"));
459			policy.addPermission(new RuntimePermission("setContextClassLoader"));
460			Policy.setPolicy(policy);
461			} catch (AccessControlException ok) {
462			return;
463			}
464	jsr166	1.20
465	dl	1.11	try {
466			Callable task = Executors.privilegedCallableUsingCurrentClassLoader(new NoOpCallable());
467			task.call();
468	jsr166	1.20	}
469	dl	1.11	finally {
470			Policy.setPolicy(savedPolicy);
471			}
472			}
473
474			/**
475			* Without permissions, calling privilegedCallable throws ACE
476			*/
477	jsr166	1.23	public void testprivilegedCallableWithNoPrivs() throws Exception {
478	dl	1.16	Callable task;
479			Policy savedPolicy = null;
480			AdjustablePolicy policy = null;
481			AccessControlContext noprivAcc = null;
482	dl	1.14	try {
483	dl	1.16	savedPolicy = Policy.getPolicy();
484			policy = new AdjustablePolicy();
485	dl	1.14	Policy.setPolicy(policy);
486	dl	1.16	noprivAcc = AccessController.getContext();
487			task = Executors.privilegedCallable(new CheckCCL());
488	dl	1.15	Policy.setPolicy(savedPolicy);
489	dl	1.14	} catch (AccessControlException ok) {
490	dl	1.16	return; // program has too few permissions to set up test
491			}
492
493	jsr166	1.20	// Make sure that program doesn't have too many permissions
494	dl	1.16	try {
495			AccessController.doPrivileged(new PrivilegedAction() {
496			public Object run() {
497			checkCCL();
498			return null;
499			}}, noprivAcc);
500			// too many permssions; skip test
501	dl	1.14	return;
502	jsr166	1.21	} catch (AccessControlException ok) {
503	dl	1.14	}
504
505	dl	1.11	try {
506	dl	1.16	task.call();
507			shouldThrow();
508	jsr166	1.23	} catch (AccessControlException success) {}
509	dl	1.11	}
510
511			/**
512			* With permissions, calling privilegedCallable succeeds
513			*/
514	jsr166	1.23	public void testprivilegedCallableWithPrivs() throws Exception {
515	dl	1.14	Policy savedPolicy = null;
516			try {
517			savedPolicy = Policy.getPolicy();
518			AdjustablePolicy policy = new AdjustablePolicy();
519			policy.addPermission(new RuntimePermission("getContextClassLoader"));
520			policy.addPermission(new RuntimePermission("setContextClassLoader"));
521			Policy.setPolicy(policy);
522			} catch (AccessControlException ok) {
523			return;
524			}
525	jsr166	1.20
526	dl	1.11	Callable task = Executors.privilegedCallable(new CheckCCL());
527			try {
528			task.call();
529			} finally {
530			Policy.setPolicy(savedPolicy);
531			}
532			}
533
534			/**
535			* callable(Runnable) returns null when called
536	jsr166	1.20	*/
537	jsr166	1.23	public void testCallable1() throws Exception {
538			Callable c = Executors.callable(new NoOpRunnable());
539			assertNull(c.call());
540	dl	1.11	}
541
542			/**
543			* callable(Runnable, result) returns result when called
544	jsr166	1.20	*/
545	jsr166	1.23	public void testCallable2() throws Exception {
546			Callable c = Executors.callable(new NoOpRunnable(), one);
547			assertEquals(one, c.call());
548	dl	1.11	}
549
550			/**
551			* callable(PrivilegedAction) returns its result when called
552	jsr166	1.20	*/
553	jsr166	1.23	public void testCallable3() throws Exception {
554			Callable c = Executors.callable(new PrivilegedAction() {
555			public Object run() { return one; }});
556	dl	1.11	assertEquals(one, c.call());
557			}
558
559			/**
560			* callable(PrivilegedExceptionAction) returns its result when called
561	jsr166	1.20	*/
562	jsr166	1.23	public void testCallable4() throws Exception {
563			Callable c = Executors.callable(new PrivilegedExceptionAction() {
564			public Object run() { return one; }});
565			assertEquals(one, c.call());
566	dl	1.11	}
567
568
569			/**
570			* callable(null Runnable) throws NPE
571	jsr166	1.20	*/
572	dl	1.11	public void testCallableNPE1() {
573			try {
574	jsr166	1.23	Callable c = Executors.callable((Runnable) null);
575			shouldThrow();
576			} catch (NullPointerException success) {}
577	dl	1.11	}
578
579			/**
580			* callable(null, result) throws NPE
581	jsr166	1.20	*/
582	dl	1.11	public void testCallableNPE2() {
583			try {
584	jsr166	1.23	Callable c = Executors.callable((Runnable) null, one);
585			shouldThrow();
586			} catch (NullPointerException success) {}
587	dl	1.11	}
588
589			/**
590			* callable(null PrivilegedAction) throws NPE
591	jsr166	1.20	*/
592	dl	1.11	public void testCallableNPE3() {
593			try {
594	jsr166	1.23	Callable c = Executors.callable((PrivilegedAction) null);
595			shouldThrow();
596			} catch (NullPointerException success) {}
597	dl	1.11	}
598
599			/**
600			* callable(null PrivilegedExceptionAction) throws NPE
601	jsr166	1.20	*/
602	dl	1.11	public void testCallableNPE4() {
603			try {
604	jsr166	1.23	Callable c = Executors.callable((PrivilegedExceptionAction) null);
605			shouldThrow();
606			} catch (NullPointerException success) {}
607	dl	1.11	}
608
609	dl	1.1
610			}