ExecutorService en Java Servlet
Necesito realizar algunas tareas (principalmente, llamar a múltiples URL externas con parámetros de solicitud y leer datos) al mismo tiempo en el servlet java y enviar una respuesta al usuario en unos pocos segundos. Estoy tratando de usar ExecutorService para lograr lo mismo. Necesito cuatro FutureTasks creadas en cada solicitud de usuario en el método doGet. Cada tarea se ejecuta durante unos 5-10 segundos y el tiempo de respuesta total para el usuario es de unos 15 segundos.
¿Puede sugerir cuál de los siguientes diseños es mejor al utilizar ExecutorService en un servlet de Java?
1) (Creando newFixedThreadPool por solicitud y cerrándolo lo antes posible)
public class MyTestServlet extends HttpServlet
{
ExecutorService myThreadPool = null;
public void init()
{
super.init();
}
protected void doGet(HttpServletRequest request,HttpServletResponse response)
{
myThreadPool = Executors.newFixedThreadPool(4);
taskOne = myThreadPool.submit();
taskTwo = myThreadPool.submit();
taskThree = myThreadPool.submit();
taskFour = myThreadPool.submit();
...
...
taskOne.get();
taskTwo.get();
taskThree.get();
taskFour.get();
...
myThreadPool.shutdown();
}
public void destroy()
{
super.destroy();
}
}
2) (Creando newFixedThreadPool durante el inicio del Servlet y apagándolo en el Servlet destroy)
public class MyTestServlet extends HttpServlet
{
ExecutorService myThreadPool = null;
public void init()
{
super.init();
//What should be the value of fixed thread pool so that it can handle multiple user requests without wait???
myThreadPool = Executors.newFixedThreadPool(20);
}
protected void doGet(HttpServletRequest request,HttpServletResponse response)
{
taskOne = myThreadPool.submit();
taskTwo = myThreadPool.submit();
taskThree = myThreadPool.submit();
taskFour = myThreadPool.submit();
...
...
taskOne.get();
taskTwo.get();
taskThree.get();
taskFour.get();
...
}
public void destroy()
{
super.destroy();
myThreadPool.shutdown();
}
}
3) (Creando newCachedThreadPool durante el Servlet Init y apagándolo en el servlet destroy)
public class MyTestServlet extends HttpServlet
{
ExecutorService myThreadPool = null;
public void init()
{
super.init();
myThreadPool = Executors.newCachedThreadPool();
}
protected void doGet(HttpServletRequest request,HttpServletResponse response)
{
taskOne = myThreadPool.submit();
taskTwo = myThreadPool.submit();
taskThree = myThreadPool.submit();
taskFour = myThreadPool.submit();
...
...
taskOne.get();
taskTwo.get();
taskThree.get();
taskFour.get();
...
}
public void destroy()
{
super.destroy();
myThreadPool.shutdown();
}
}