demonstrate livelock on java ThreadPoolExecutor

LiveLockExample.java

package jon;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class LiveLockExample {


  public static void main(String[] args) throws Exception {
    final ExecutorService pool = Executors.newFixedThreadPool(1);
    runLiveLock(pool);
    pool.shutdownNow();

    final ForkJoinPool fjPool = new ForkJoinPool(1);
    runLiveLock(fjPool);
    fjPool.shutdownNow();
  }

  private static void runLiveLock(final ExecutorService pool) throws InterruptedException, ExecutionException {
    Future<Void> outerFuture = pool.submit(new Callable<Void>() {

      @Override
      public Void call() throws Exception {
        System.out.println("Pre submit on outer thread " + Thread.currentThread().getName());
        Future<Void> innerFuture = pool.submit(new Callable<Void>() {

          @Override
          public Void call() throws Exception {
            System.out.println("Inner call on thread " + Thread.currentThread().getName());
            return null;
          }
        });
        innerFuture.get();
        System.out.println("Post submit on outer thread " + Thread.currentThread().getName());
        return null;
      }
    });
    try {
      outerFuture.get(3, TimeUnit.SECONDS);
    } catch (TimeoutException e) {
      System.out.println("FAILED: Got a timeout waiting for outerFuture");
    }
  }

}