Examples of javax.servlet.AsyncContext.start()

javax.servlet.AsyncContext.start()
Causes the container to dispatch a thread to run the specified Runnable in the {@link ServletContext} that initialized this AsyncContext. @param run the asynchronous handler

        @Override
        protected void doGet(HttpServletRequest req,
                final HttpServletResponse resp)
                throws ServletException, IOException {
            final AsyncContext ctx = req.startAsync();
            ctx.start(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(THREAD_SLEEP_TIME);
                        resp.setHeader("A", "xyz");

View Full Code Here

        protected void doGet(HttpServletRequest req, HttpServletResponse resp)
                throws ServletException, IOException {


            final AsyncContext actxt = req.startAsync();
            actxt.setTimeout(TIMEOUT);
            actxt.start(new Runnable() {
                @Override
                public void run() {
                    try {
                        ((HttpServletResponse) actxt.getResponse()).sendError(
                                status);

View Full Code Here

            final AsyncContext asyncContext =
                request.startAsync(request, response);


            asyncContext.addListener(new TrackingListener(false, false, null));


            asyncContext.start(new Runnable() {


                @Override
                public void run() {
                    try {
                        Thread.sleep(THREAD_SLEEP_TIME);

View Full Code Here

        @Override
        protected void doGet(HttpServletRequest req,
                final HttpServletResponse resp)
                throws ServletException, IOException {
            final AsyncContext ctx = req.startAsync(); 
            ctx.start(new Runnable() { 
                @Override
                public void run() { 
                    try { 
                        Thread.sleep(THREAD_SLEEP_TIME); 
                        resp.setHeader("A", "xyz");

View Full Code Here

        protected void doGet(HttpServletRequest req, HttpServletResponse resp)
                throws ServletException, IOException {
            
            final AsyncContext actxt = req.startAsync();
            actxt.setTimeout(TIMEOUT);
            actxt.start(new Runnable() {
                @Override
                public void run() {
                    try {
                        ((HttpServletResponse) actxt.getResponse()).sendError(
                                status);

View Full Code Here

            final AsyncContext asyncContext =
                request.startAsync(request, response);


            asyncContext.addListener(new TrackingListener(false, false, null));


            asyncContext.start(new Runnable() {


                @Override
                public void run() {
                    try {
                        Thread.sleep(THREAD_SLEEP_TIME);

View Full Code Here

        @Override
        protected void doGet(HttpServletRequest req,
                final HttpServletResponse resp)
                throws ServletException, IOException {
            final AsyncContext ctx = req.startAsync();
            ctx.start(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(THREAD_SLEEP_TIME);
                        resp.setHeader("A", "xyz");

View Full Code Here

                throws ServletException, IOException {


            final AsyncContext actxt = req.startAsync();
            actxt.setTimeout(TIMEOUT);
            if (threaded) {
                actxt.start(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            HttpServletResponse resp =
                                    (HttpServletResponse) actxt.getResponse();

View Full Code Here

        if (value == null) {
            value = new AtomicInteger(0);
            session.setAttribute(ATTRIBUTE, value);
        }
        AsyncContext context = request.startAsync(request, response);
        context.start(new AsyncTask(context));
    }


    private static class AsyncTask implements Runnable {
        private final AsyncContext context;

View Full Code Here

            final AsyncContext asyncContext =
                request.startAsync(request, response);


            asyncContext.addListener(new TrackingListener(false, false, null));


            asyncContext.start(new Runnable() {


                @Override
                public void run() {
                    try {
                        Thread.sleep(3 * 1000);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.