ViewVC Help

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

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

Comparing jsr166/src/test/tck/ThreadPoolExecutorTest.java (file contents):
Revision 1.18 by dl, Tue Jan 20 20:30:08 2004 UTC vs.
Revision 1.19 by dl, Sat Apr 10 14:27:17 2004 UTC

#	Line 36 | Line 36 | public class ThreadPoolExecutorTest exte
36		}
37		}
38
39	+	static class FailingThreadFactory implements ThreadFactory{
40	+	int calls = 0;
41	+	public Thread newThread(Runnable r){
42	+	if (++calls > 1) throw new NullPointerException();
43	+	return new Thread(r);
44	+	}
45	+	}
46	+
47	+
48		/**
49		*  execute successfully executes a runnable
50		*/
#	Line 1498 | Line 1507 | public class ThreadPoolExecutorTest exte
1507		}
1508		}
1509
1510	<
1510	>	/**
1511	>	* Execution continues if there is at least one thread even if
1512	>	* thread factory fails to create more
1513	>	*/
1514	>	public void testFailingThreadFactory() {
1515	>	ExecutorService e = new ThreadPoolExecutor(100, 100, LONG_DELAY_MS, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), new FailingThreadFactory());
1516	>	try {
1517	>	ArrayList<Callable<String>> l = new ArrayList<Callable<String>>();
1518	>	for (int k = 0; k < 100; ++k) {
1519	>	e.execute(new NoOpRunnable());
1520	>	}
1521	>	Thread.sleep(LONG_DELAY_MS);
1522	>	} catch(Exception ex) {
1523	>	unexpectedException();
1524	>	} finally {
1525	>	joinPool(e);
1526	>	}
1527	>	}
1528		}

Diff Legend

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