Class FutureTaskTest

test/FutureTaskTest.java:8–105

import java.util.concurrent.TimeoutException;

public class FutureTaskTest {
  private static final int DELAY_TIME = 10;
  
  public static void main(String[] args) throws InterruptedException, ExecutionException {
    isDoneTest(false);
    isDoneTest(true);
    getCallableResultTest();
    getRunnableResultTest();
    getTimeoutFail();
    getExecutionExceptionTest();
  }
  
  private static void isDoneTest(final boolean throwException) {
    RunnableFuture<?> future = new FutureTask<Object>(new Runnable() {
      @Override
      public void run() {
        if (throwException) {
          throw new RuntimeException();
        }
      }
    }, null);
    
    // should finish the future
    future.run();
    
    if (! future.isDone()) {
      throw new RuntimeException("Future should be done");
    }
  }
  
  private static void getCallableResultTest() throws InterruptedException, ExecutionException {
    final Object result = new Object();
    FutureTask<Object> future = new FutureTask<Object>(new Callable<Object>() {
      @Override
      public Object call() throws Exception {
        return result;
      }
    });
    
    future.run();
    if (future.get() != result) {
      throw new RuntimeException("Bad result returned: " + future.get());
    }
  }
  
  private static void getRunnableResultTest() throws InterruptedException, ExecutionException {
    final Object result = new Object();
    FutureTask<Object> future = new FutureTask<Object>(new Runnable() {
      @Override
      public void run() {
        // nothing here
      }
    }, result);
    
    future.run();
    if (future.get() != result) {
      throw new RuntimeException("Bad result returned: " + future.get());
    }