@WebServlet("/foo", asyncSupported=true)
public class MyServlet extends HttpServlet {

@Resourse(name = "myDBRef")
private DataSource dataSource;

//есть ли смысл создавать больше?
private ScheduledThreadPoolExecutor executor = new ThreadPoolExecutor(10);


    public void doGet(HttpServletRequest req, HttpServletResponse res) {
        // Обрабатываем запрос
        // Формируем контекст асинхронной обработки
        final AsyncContext aCtx = request.startAsync(req, res);
        // запускаем обращение к медленным ресурсам в отдельном потоке.
        executor.submit(new Callable<Object>(){  
                    public Object call() throws Exception  
                    {  
                             //  тут соединение с базой и получение данных.
                             //  а если это будет не процедура а select ?
                              Connection conn = dataSource.getConnection();   
                              CallableStatement cst = conn.prepareCall("call doSomeAnalytics()");  
                              cst.execute();   
                              async.getResponse().getWriter().print("Database procedure executed");   
                              async.complete();  
                              conn.close();
                              return this;   
                    }  

    }
}

public class WsConnection extends MessageInbound {

 public static ArrayBlockingQueue<WsOutbound> connections = new ArrayBlockingQueue<WsOutbound>();

 private WsOutbound outbound;

@Override
    protected void onTextMessage(CharBuffer charBuffer) throws IOException {
        broadcast(charBuffer.toString());
    }
 
    @Override
    protected void onOpen(WsOutbound outbound) {
        this.outbound = outbound;
        connections.add(outbound);
    }
 
    @Override
    protected void onClose(int status) {
        connections.remove(this.outbound);
    }
 
    private void broadcast(String message) {
        for (WsOutbound connection : connections) {
            try {
                CharBuffer buffer = CharBuffer.wrap(message);
                connection.writeTextMessage(buffer);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}