ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AbstractExecutorServiceTest.java
(Generate patch)

Comparing jsr166/src/test/tck/AbstractExecutorServiceTest.java (file contents):
Revision 1.12 by dl, Mon Jan 12 16:37:40 2004 UTC vs.
Revision 1.13 by dl, Mon Jan 12 19:39:21 2004 UTC

# Line 240 | Line 240 | public class AbstractExecutorServiceTest
240       * executor is saturated.
241       */
242      public void testExecute1() {
243 <        ThreadPoolExecutor p = new ThreadPoolExecutor(1,1, SHORT_DELAY_MS, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1));
243 >        ThreadPoolExecutor p = new ThreadPoolExecutor(1,1, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1));
244          try {
245  
246              for(int i = 0; i < 5; ++i){
# Line 256 | Line 256 | public class AbstractExecutorServiceTest
256       * if executor is saturated.
257       */
258      public void testExecute2() {
259 <         ThreadPoolExecutor p = new ThreadPoolExecutor(1,1, SHORT_DELAY_MS, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1));
259 >         ThreadPoolExecutor p = new ThreadPoolExecutor(1,1, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1));
260          try {
261              for(int i = 0; i < 5; ++i) {
262                  p.submit(new SmallCallable());
# Line 272 | Line 272 | public class AbstractExecutorServiceTest
272       *  caller interrupted.
273       */
274      public void testInterruptedSubmit() {
275 <        final ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,SHORT_DELAY_MS, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
275 >        final ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
276          Thread t = new Thread(new Runnable() {
277                  public void run() {
278                      try {
# Line 308 | Line 308 | public class AbstractExecutorServiceTest
308       *  interrupted
309       */
310      public void testSubmitIE() {
311 <        final ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,SHORT_DELAY_MS, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
311 >        final ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
312  
313          final Callable c = new Callable() {
314                  public Object call() {
# Line 348 | Line 348 | public class AbstractExecutorServiceTest
348       *  throws exception
349       */
350      public void testSubmitEE() {
351 <        ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,SHORT_DELAY_MS, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
351 >        ThreadPoolExecutor p = new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
352  
353          try {
354              Callable c = new Callable() {
# Line 764 | Line 764 | public class AbstractExecutorServiceTest
764              l.add(new StringTask());
765              l.add(Executors.callable(new MediumPossiblyInterruptedRunnable(), TEST_STRING));
766              l.add(new StringTask());
767 <            List<Future<String>> result = e.invokeAll(l, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
767 >            List<Future<String>> result = e.invokeAll(l, MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);
768              assertEquals(3, result.size());
769              Iterator<Future<String>> it = result.iterator();
770              Future<String> f1 = it.next();

Diff Legend

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