[cvs] / jsr166 / src / test / tck / FutureTaskTest.java Repository:
ViewVC logotype

Diff of /jsr166/src/test/tck/FutureTaskTest.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.13, Mon Nov 16 04:57:10 2009 UTC revision 1.20, Thu Sep 16 00:52:49 2010 UTC
# Line 8  Line 8 
8    
9  import junit.framework.*;  import junit.framework.*;
10  import java.util.concurrent.*;  import java.util.concurrent.*;
11    import static java.util.concurrent.TimeUnit.MILLISECONDS;
12  import java.util.*;  import java.util.*;
13    
14  public class FutureTaskTest extends JSR166TestCase {  public class FutureTaskTest extends JSR166TestCase {
# Line 36  Line 37 
37          try {          try {
38              FutureTask task = new FutureTask(null);              FutureTask task = new FutureTask(null);
39              shouldThrow();              shouldThrow();
40          }          } catch (NullPointerException success) {}
         catch (NullPointerException success) {  
         }  
41      }      }
42    
43      /**      /**
# Line 48  Line 47 
47          try {          try {
48              FutureTask task = new FutureTask(null, Boolean.TRUE);              FutureTask task = new FutureTask(null, Boolean.TRUE);
49              shouldThrow();              shouldThrow();
50          }          } catch (NullPointerException success) {}
         catch (NullPointerException success) {  
         }  
51      }      }
52    
53      /**      /**
# Line 88  Line 85 
85      /**      /**
86       * setting value causes get to return it       * setting value causes get to return it
87       */       */
88      public void testSet() {      public void testSet() throws Exception {
89          PublicFutureTask task = new PublicFutureTask(new NoOpCallable());          PublicFutureTask task = new PublicFutureTask(new NoOpCallable());
90          task.set(one);          task.set(one);
91          try {          assertSame(task.get(), one);
             assertEquals(task.get(), one);  
         }  
         catch (Exception e) {  
             unexpectedException();  
         }  
92      }      }
93    
94      /**      /**
95       * setException causes get to throw ExecutionException       * setException causes get to throw ExecutionException
96       */       */
97      public void testSetException() {      public void testSetException() throws Exception {
98          Exception nse = new NoSuchElementException();          Exception nse = new NoSuchElementException();
99          PublicFutureTask task = new PublicFutureTask(new NoOpCallable());          PublicFutureTask task = new PublicFutureTask(new NoOpCallable());
100          task.setException(nse);          task.setException(nse);
101          try {          try {
102              Object x = task.get();              Object x = task.get();
103              shouldThrow();              shouldThrow();
104          }          } catch (ExecutionException success) {
105          catch (ExecutionException ee) {              assertSame(success.getCause(), nse);
             Throwable cause = ee.getCause();  
             assertEquals(cause, nse);  
         }  
         catch (Exception e) {  
             unexpectedException();  
106          }          }
107      }      }
108    
# Line 155  Line 142 
142      /**      /**
143       * cancel(true) interrupts a running task       * cancel(true) interrupts a running task
144       */       */
145      public void testCancelInterrupt() {      public void testCancelInterrupt() throws InterruptedException {
146          FutureTask task = new FutureTask( new Callable() {          final FutureTask task =
147                  public Object call() {              new FutureTask(new CheckedInterruptedCallable<Object>() {
148                      try {                  public Object realCall() throws InterruptedException {
149                          Thread.sleep(MEDIUM_DELAY_MS);                      Thread.sleep(SMALL_DELAY_MS);
                         threadShouldThrow();  
                     }  
                     catch (InterruptedException success) {}  
150                      return Boolean.TRUE;                      return Boolean.TRUE;
151                  } });                  } });
152    
153          Thread t = new  Thread(task);          Thread t = new  Thread(task);
154          t.start();          t.start();
   
         try {  
155              Thread.sleep(SHORT_DELAY_MS);              Thread.sleep(SHORT_DELAY_MS);
156              assertTrue(task.cancel(true));              assertTrue(task.cancel(true));
157              t.join();              t.join();
158              assertTrue(task.isDone());              assertTrue(task.isDone());
159              assertTrue(task.isCancelled());              assertTrue(task.isCancelled());
         } catch (InterruptedException e){  
             unexpectedException();  
         }  
160      }      }
161    
162    
163      /**      /**
164       * cancel(false) does not interrupt a running task       * cancel(false) does not interrupt a running task
165       */       */
166      public void testCancelNoInterrupt() {      public void testCancelNoInterrupt() throws InterruptedException {
167          FutureTask task = new FutureTask( new Callable() {          final FutureTask task =
168                  public Object call() {              new FutureTask(new CheckedCallable<Object>() {
169                      try {                  public Object realCall() throws InterruptedException {
170                          Thread.sleep(MEDIUM_DELAY_MS);                          Thread.sleep(MEDIUM_DELAY_MS);
                     }  
                     catch (InterruptedException success) {  
                         threadFail("should not interrupt");  
                     }  
171                      return Boolean.TRUE;                      return Boolean.TRUE;
172                  } });                  } });
173    
174          Thread t = new  Thread(task);          Thread t = new  Thread(task);
175          t.start();          t.start();
   
         try {  
176              Thread.sleep(SHORT_DELAY_MS);              Thread.sleep(SHORT_DELAY_MS);
177              assertTrue(task.cancel(false));              assertTrue(task.cancel(false));
178              t.join();              t.join();
179              assertTrue(task.isDone());              assertTrue(task.isDone());
180              assertTrue(task.isCancelled());              assertTrue(task.isCancelled());
         } catch (InterruptedException e){  
             unexpectedException();  
         }  
181      }      }
182    
183      /**      /**
184       * set in one thread causes get in another thread to retrieve value       * set in one thread causes get in another thread to retrieve value
185       */       */
186      public void testGet1() {      public void testGet1() throws InterruptedException {
187          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft =
188                  public Object call() {              new FutureTask(new CheckedCallable<Object>() {
189                      try {                  public Object realCall() throws InterruptedException {
                         Thread.sleep(MEDIUM_DELAY_MS);  
                     } catch (InterruptedException e){  
                         threadUnexpectedException();  
                     }  
190                      return Boolean.TRUE;                      return Boolean.TRUE;
191                  }                  }});
192          });          Thread t = new Thread(new CheckedRunnable() {
193          Thread t = new Thread(new Runnable() {              public void realRun() throws Exception {
194                  public void run() {                  assertSame(Boolean.TRUE, ft.get());
195                      try {              }});
196                          ft.get();  
                     } catch (Exception e){  
                         threadUnexpectedException();  
                     }  
                 }  
             });  
         try {  
197              assertFalse(ft.isDone());              assertFalse(ft.isDone());
198              assertFalse(ft.isCancelled());              assertFalse(ft.isCancelled());
199              t.start();              t.start();
# Line 240  Line 202 
202              t.join();              t.join();
203              assertTrue(ft.isDone());              assertTrue(ft.isDone());
204              assertFalse(ft.isCancelled());              assertFalse(ft.isCancelled());
         } catch (InterruptedException e){  
             unexpectedException();  
   
         }  
205      }      }
206    
207      /**      /**
208       * set in one thread causes timed get in another thread to retrieve value       * set in one thread causes timed get in another thread to retrieve value
209       */       */
210      public void testTimedGet1() {      public void testTimedGet1() throws InterruptedException {
211          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft =
212                  public Object call() {              new FutureTask(new CheckedCallable<Object>() {
213                      try {                  public Object realCall() throws InterruptedException {
                         Thread.sleep(MEDIUM_DELAY_MS);  
                     } catch (InterruptedException e){  
                         threadUnexpectedException();  
                     }  
214                      return Boolean.TRUE;                      return Boolean.TRUE;
215                  }                  }});
216              });          Thread t = new Thread(new CheckedRunnable() {
217          Thread t = new Thread(new Runnable() {              public void realRun() throws Exception {
218                  public void run() {                  assertSame(Boolean.TRUE, ft.get(SMALL_DELAY_MS, MILLISECONDS));
219                      try {              }});
220                          ft.get(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);  
                     } catch (TimeoutException success) {  
                     } catch (Exception e){  
                         threadUnexpectedException();  
                     }  
                 }  
             });  
         try {  
221              assertFalse(ft.isDone());              assertFalse(ft.isDone());
222              assertFalse(ft.isCancelled());              assertFalse(ft.isCancelled());
223              t.start();              t.start();
224            Thread.sleep(SHORT_DELAY_MS);
225              ft.run();              ft.run();
226              t.join();              t.join();
227              assertTrue(ft.isDone());              assertTrue(ft.isDone());
228              assertFalse(ft.isCancelled());              assertFalse(ft.isCancelled());
         } catch (InterruptedException e){  
             unexpectedException();  
   
         }  
229      }      }
230    
231      /**      /**
232       *  Cancelling a task causes timed get in another thread to throw CancellationException       *  Cancelling a task causes timed get in another thread to throw
233         *  CancellationException
234       */       */
235      public void testTimedGet_Cancellation() {      public void testTimedGet_Cancellation() throws InterruptedException {
236          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft =
237                  public Object call() {              new FutureTask(new CheckedInterruptedCallable<Object>() {
238                      try {                  public Object realCall() throws InterruptedException {
239                          Thread.sleep(SMALL_DELAY_MS);                          Thread.sleep(SMALL_DELAY_MS);
                         threadShouldThrow();  
                     } catch (InterruptedException e) {  
                     }  
240                      return Boolean.TRUE;                      return Boolean.TRUE;
241                  }                  }});
242              });  
243          try {          Thread t1 = new ThreadShouldThrow(CancellationException.class) {
244              Thread t1 = new Thread(new Runnable() {              public void realRun() throws Exception {
245                      public void run() {                  ft.get(MEDIUM_DELAY_MS, MILLISECONDS);
246                          try {              }};
                             ft.get(MEDIUM_DELAY_MS, TimeUnit.MILLISECONDS);  
                             threadShouldThrow();  
                         } catch (CancellationException success) {}  
                         catch (Exception e){  
                             threadUnexpectedException();  
                         }  
                     }  
                 });  
247              Thread t2 = new Thread(ft);              Thread t2 = new Thread(ft);
248              t1.start();              t1.start();
249              t2.start();              t2.start();
# Line 317  Line 251 
251              ft.cancel(true);              ft.cancel(true);
252              t1.join();              t1.join();
253              t2.join();              t2.join();
         } catch (InterruptedException ie){  
             unexpectedException();  
         }  
254      }      }
255    
256      /**      /**
257       * Cancelling a task causes get in another thread to throw CancellationException       * Cancelling a task causes get in another thread to throw
258         * CancellationException
259       */       */
260      public void testGet_Cancellation() {      public void testGet_Cancellation() throws InterruptedException {
261          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft =
262                  public Object call() {              new FutureTask(new CheckedInterruptedCallable<Object>() {
263                      try {                  public Object realCall() throws InterruptedException {
264                          Thread.sleep(MEDIUM_DELAY_MS);                      Thread.sleep(SMALL_DELAY_MS);
                         threadShouldThrow();  
                     } catch (InterruptedException e){  
                     }  
265                      return Boolean.TRUE;                      return Boolean.TRUE;
266                  }                  }});
267              });          Thread t1 = new ThreadShouldThrow(CancellationException.class) {
268          try {              public void realRun() throws Exception {
             Thread t1 = new Thread(new Runnable() {  
                     public void run() {  
                         try {  
269                              ft.get();                              ft.get();
270                              threadShouldThrow();              }};
271                          } catch (CancellationException success){  
                         }  
                         catch (Exception e){  
                             threadUnexpectedException();  
                         }  
                     }  
                 });  
272              Thread t2 = new Thread(ft);              Thread t2 = new Thread(ft);
273              t1.start();              t1.start();
274              t2.start();              t2.start();
# Line 356  Line 276 
276              ft.cancel(true);              ft.cancel(true);
277              t1.join();              t1.join();
278              t2.join();              t2.join();
         } catch (InterruptedException success){  
             unexpectedException();  
         }  
279      }      }
280    
281    
282      /**      /**
283       * A runtime exception in task causes get to throw ExecutionException       * A runtime exception in task causes get to throw ExecutionException
284       */       */
285      public void testGet_ExecutionException() {      public void testGet_ExecutionException() throws InterruptedException {
286          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft = new FutureTask(new Callable() {
287                  public Object call() {                  public Object call() {
288                      int i = 5/0;                  return 5/0;
289                      return Boolean.TRUE;              }});
290                  }  
             });  
         try {  
291              ft.run();              ft.run();
292            try {
293              ft.get();              ft.get();
294              shouldThrow();              shouldThrow();
295          } catch (ExecutionException success){          } catch (ExecutionException success){
296          }              assertTrue(success.getCause() instanceof ArithmeticException);
         catch (Exception e){  
             unexpectedException();  
297          }          }
298      }      }
299    
300      /**      /**
301       *  A runtime exception in task causes timed get to throw ExecutionException       *  A runtime exception in task causes timed get to throw ExecutionException
302       */       */
303      public void testTimedGet_ExecutionException2() {      public void testTimedGet_ExecutionException2() throws Exception {
304          final FutureTask ft = new FutureTask(new Callable() {          final FutureTask ft = new FutureTask(new Callable() {
305                  public Object call() {                  public Object call() {
306                      int i = 5/0;                  return 5/0;
307                      return Boolean.TRUE;              }});
308                  }  
             });  
         try {  
309              ft.run();              ft.run();
310              ft.get(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);          try {
311                ft.get(SHORT_DELAY_MS, MILLISECONDS);
312              shouldThrow();              shouldThrow();
313          } catch (ExecutionException success) {          } catch (ExecutionException success) {
314          } catch (TimeoutException success) { } // unlikely but OK              assertTrue(success.getCause() instanceof ArithmeticException);
         catch (Exception e){  
             unexpectedException();  
315          }          }
316      }      }
317    
# Line 408  Line 319 
319      /**      /**
320       * Interrupting a waiting get causes it to throw InterruptedException       * Interrupting a waiting get causes it to throw InterruptedException
321       */       */
322      public void testGet_InterruptedException() {      public void testGet_InterruptedException() throws InterruptedException {
323          final FutureTask ft = new FutureTask(new NoOpCallable());          final FutureTask ft = new FutureTask(new NoOpCallable());
324          Thread t = new Thread(new Runnable() {          Thread t = new Thread(new CheckedInterruptedRunnable() {
325                  public void run() {              public void realRun() throws Exception {
                     try {  
326                          ft.get();                          ft.get();
327                          threadShouldThrow();              }});
328                      } catch (InterruptedException success){  
                     } catch (Exception e){  
                         threadUnexpectedException();  
                     }  
                 }  
             });  
         try {  
329              t.start();              t.start();
330              Thread.sleep(SHORT_DELAY_MS);              Thread.sleep(SHORT_DELAY_MS);
331              t.interrupt();              t.interrupt();
332              t.join();              t.join();
         } catch (Exception e){  
             unexpectedException();  
         }  
333      }      }
334    
335      /**      /**
336       *  Interrupting a waiting timed get causes it to throw InterruptedException       *  Interrupting a waiting timed get causes it to throw InterruptedException
337       */       */
338      public void testTimedGet_InterruptedException2() {      public void testTimedGet_InterruptedException2() throws InterruptedException {
339          final FutureTask ft = new FutureTask(new NoOpCallable());          final FutureTask ft = new FutureTask(new NoOpCallable());
340          Thread t = new Thread(new Runnable() {          Thread t = new Thread(new CheckedInterruptedRunnable() {
341                  public void run() {              public void realRun() throws Exception {
342                      try {                  ft.get(LONG_DELAY_MS,MILLISECONDS);
343                          ft.get(LONG_DELAY_MS,TimeUnit.MILLISECONDS);              }});
344                          threadShouldThrow();  
                     } catch (InterruptedException success){}  
                     catch (Exception e){  
                         threadUnexpectedException();  
                     }  
                 }  
             });  
         try {  
345              t.start();              t.start();
346              Thread.sleep(SHORT_DELAY_MS);              Thread.sleep(SHORT_DELAY_MS);
347              t.interrupt();              t.interrupt();
348              t.join();              t.join();
         } catch (Exception e){  
             unexpectedException();  
         }  
349      }      }
350    
351      /**      /**
352       * A timed out timed get throws TimeoutException       * A timed out timed get throws TimeoutException
353       */       */
354      public void testGet_TimeoutException() {      public void testGet_TimeoutException() throws Exception {
355          try {          try {
356              FutureTask ft = new FutureTask(new NoOpCallable());              FutureTask ft = new FutureTask(new NoOpCallable());
357              ft.get(1,TimeUnit.MILLISECONDS);              ft.get(1,MILLISECONDS);
358              shouldThrow();              shouldThrow();
359          } catch (TimeoutException success){}          } catch (TimeoutException success){}
         catch (Exception success){  
             unexpectedException();  
         }  
360      }      }
361    
362  }  }

Legend:
Removed from v.1.13  
changed lines
  Added in v.1.20

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8