Illustration of ListeningExecutorService

ListeningExecutorServiceIllus.java

    
    class ListeningExecutorServiceIllus
    {
    //Just for illustration purpose, not a working version.
		//Creation of ListeningExecutorService
		
		class MyCallbackRunnable implements Runnable
		{

			@Override
			public void run() {
				System.out.println(" I got called by a listenable future");
				
			}
			
		}
		
		public void illustrationMethod()
		{
		ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
		
		//Creation of ListenableFuture
		ListenableFuture listeningFuture = service.submit(new Callable() {
		  public ReturnType call() {
			  Thread.sleep(20000);
			  ReturnType returnVariable = new ReturnType();
			  return returnVariable;
		  }
		});
		
		//Creation of callback executor
		Executor mycallbackExecutor = Executors.newFixedThreadPool(10);
		
		
		//Registering callbacks with listenableFuture
		listeningFuture.addListener(new MyCallbackRunnable(),mycallbackExecutor );
    }
    }