package org.apidesign.deadlock;

 import java.util.concurrent.ExecutorService;

 import java.util.concurrent.Executors;

 import java.util.concurrent.Future;

 import java.util.concurrent.TimeUnit;

 import org.junit.Assert;

 import org.junit.Test;

 public class ExecutorServiceTest implements Runnable {

     private int cnt;

     @Test

     public void showUsageOfExecutionService() throws Exception {

         Runnable someRunnable = this;

         // BEGIN: deadlock.service

         ExecutorService service = Executors.newSingleThreadExecutor();

         // scheduling is quite different

         Future<?> task = service.submit(someRunnable);

         // compared to waiting

         task.get(1000, TimeUnit.MILLISECONDS);

         // END: deadlock.service

         Assert.assertEquals("Cnt executed", 1, cnt);

     }

     public void run() {

         cnt++;

     }

 }