ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/ExecutorsTest.java

Comparing jsr166/src/test/tck/ExecutorsTest.java (file contents):
Revision 1.1 by dl, Sun Aug 31 19:24:55 2003 UTC vs.
Revision 1.11 by dl, Mon Dec 22 00:48:55 2003 UTC

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

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines