Java Futures y Enterprise Java Beans

El concepto de Java Futures esta ligado a la programación asíncrona . Vamos a usar Java Futures con Enterprise Java Beans  para entender  su utilidad.  Para ello partiremos de dos 2  EJBs  asíncronos que  ejecutaran una tarea que tarda 5s y  devuelven un Java Future.

 

 

 

 

 

¿Para que sirven los Java Futures?

Un Java Future es un objeto que se construye para albergar un valor en un futuro. Vamos a verlos funcionando en código.

package com.arquitecturajava.ejb;

import java.util.concurrent.Future;

import javax.ejb.AsyncResult;
import javax.ejb.Asynchronous;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;

@Stateless
@LocalBean
public class ServicioEJB2 {
 
 @Asynchronous
 public Future<String> getMensaje2() {
 try {
 Thread.sleep(5000);
 } catch (InterruptedException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
 }
 
 return new AsyncResult<String>("mensaje2 lento");
 }

}

package com.arquitecturajava.ejb;

import java.util.concurrent.Future;

import javax.ejb.AsyncResult;
import javax.ejb.Asynchronous;
import javax.ejb.LocalBean;
import javax.ejb.Stateless;

@Stateless
@LocalBean
public class ServicioEJB1 {

 
 @Asynchronous
 public Future<String> getMensaje1() {
 try {
 Thread.sleep(5000);
 } catch (InterruptedException e) {
 // TODO Auto-generated catch block
 e.printStackTrace();
 }
 
 return new AsyncResult<String>("mensaje1 lento");
 }

}

En este caso tenemos dos EJBs y cada uno tiene un método getMensaje() . Con una programación normal cada EJB devolvería un String . Sin embargo en este caso al tratarse de EJBS asíncronos cada uno devuelve un Java Future a través de una variable de tipo AsyncResult. Vamos a usar un Servlet para acceder a ellos.

 

 

El código del servlet:

package com.arquitecturajava.servlets;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

import javax.ejb.EJB;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.arquitecturajava.ejb.ServicioEJB1;
import com.arquitecturajava.ejb.ServicioEJB2;

@WebServlet("/ServletEJB")
public class ServletEJB extends HttpServlet {
 private static final long serialVersionUID = 1L;
       
 @EJB
 ServicioEJB1 servicio1;
 
 @EJB 
 ServicioEJB2 servicio2;
 
 protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
   
  Future<String> futuro1=servicio1.getMensaje1();
  Future<String> futuro2= servicio2.getMensaje2();
  
  while(!futuro1.isDone() && !futuro2.isDone()) {
   
   try {
    Thread.sleep(6000);
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  }
  
  
  PrintWriter pw=response.getWriter();
  try {
   pw.println(futuro1.get());
   pw.println(futuro2.get());
   
   
  } catch (InterruptedException e) {
  
   e.printStackTrace();
  } catch (ExecutionException e) {
  
   e.printStackTrace();
  }
 }
 
 
}

En este caso recibimos cada uno de los Futures creados por los EJBs. Usamos un bucle while y comprobamos el método isDone() de cada future para saber si ambas tareas han finalizado. En caso de no haber terminado  ponemos el Servlet a dormir.

while(!futuro1.isDone() && !futuro2.isDone()) {
 .. sleep
}

Cuando ambos EJBs asíncronos han terminado su ejecución los métodos isDone() devolverán true. En esa situación ya podemos acceder a los valores futuros e imprimirlos por la pantalla.

De esta forma conseguiremos que aunque ambos EJBs tardan 5 segundos en ejecutarse  las peticiones se ejecuten en paralelo y en 6 segundos hayamos terminado.

Otros artículos relacionados: EJB Async  , EJB Remote vs Local (JEE 6), Introducción a EJB 3.1 (I)