/**
 * @ClassName AsyncServlet
 * @Desc 自定義異步Servlet處理器
 * @Author xieqx
 * @Date 2020/12/9 15:38
 **/
//通過(guò)注解的形式開(kāi)始異步
@WebServlet(urlPatterns = "*.async",asyncSupported = true)
public class AsyncServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
       doPost(req,resp);
    }
    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        //開(kāi)啟異步支持
        //異步管理上下文
        resp.setCharacterEncoding("GBK");
        PrintWriter writer = resp.getWriter();
        writer.println("周工作任務(wù)布置開(kāi)始");
        AsyncContext asyncContext = req.startAsync();
        asyncContext.start(new WeekTask(asyncContext));
        //添加監(jiān)聽(tīng)器 處理完成監(jiān)聽(tīng)
        asyncContext.addListener(new AsyncListener() {
            @Override
            public void onComplete(AsyncEvent asyncEvent) throws IOException {
                System.out.println("工作在"+new Date()+"處理完成");
            }
            @Override
            public void onTimeout(AsyncEvent asyncEvent) throws IOException {
                System.out.println("工作在"+new Date()+"處理超時(shí)");
            }
            @Override
            public void onError(AsyncEvent asyncEvent) throws IOException {
                System.out.println("工作在"+new Date()+"處理出錯(cuò)");
            }
            @Override
            public void onStartAsync(AsyncEvent asyncEvent) throws IOException {
                System.out.println("工作在"+new Date()+"處理開(kāi)始");
            }
        });
        writer.println("周工作任務(wù)布置完成");
        writer.flush();
    }
}

	<servlet>
		<servlet-name>asyncServlet</servlet-name>
		<servlet-class>com.xiu.async.servlet.AsyncServlet</servlet-class>
		<!-- 開(kāi)啟servlet的異步請(qǐng)求操作 -->
		<async-supported>true</async-supported>
	</servlet>
	<servlet-mapping>
		<servlet-name>asyncServlet</servlet-name>
		<url-pattern>*.async</url-pattern>
	</servlet-mapping>

/**
 * @ClassName WeekTask
 * @Desc 每周任務(wù) 
 * @Author xieqx
 * @Date 2020/12/10 9:36
 **/
public class WeekTask implements Runnable {
 
    private List<Job> jobs = null;
 
    private AsyncContext asyncContext = null;
    //這里初始化產(chǎn)品任務(wù)PmJob、研發(fā)任務(wù)RDJob  測(cè)試任務(wù)TestJob
    public WeekTask(AsyncContext asyncContext) {
       this.asyncContext = asyncContext;
       jobs = new ArrayList<>();
       PmJob pmJob = new PmJob();
       RDJob rdJob = new RDJob();
       TestJob testJob = new TestJob();
       jobs.add(pmJob);
       jobs.add(rdJob);
       jobs.add(testJob);
    }
 
    @Override
    public void run() {
        for(Job job:jobs){
            job.execute();
        }
        System.out.println("周任務(wù)工作完成");
        //job執(zhí)行完成后通知
      asyncContext.complete();
    }
}

/**
 * @ClassName PmTask
 * @Desc 產(chǎn)品經(jīng)理任務(wù)
 * @Author xieqx
 * @Date 2020/12/9 16:03
 **/
public class PmJob implements Job {
    @Override
    public void execute() {
        System.out.println("產(chǎn)品經(jīng)理開(kāi)評(píng)審會(huì)議");
        try {
            Thread.sleep(10);
            System.out.println("模擬需求評(píng)審會(huì)議...");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

/**
 * @ClassName PmTask
 * @Desc 研發(fā)任務(wù)
 * @Author xieqx
 * @Date 2020/12/9 16:03
 **/
public class RDJob implements Job {
    @Override
    public void execute() {
        System.out.println("程序猿開(kāi)始開(kāi)發(fā)");
        try {
            Thread.sleep(10);
            System.out.println("程序猿哼哧哼哧干活中...");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

/**
 * @ClassName TestJob
 * @Desc 測(cè)試任務(wù)
 * @Author xieqx
 * @Date 2020/12/9 16:03
 **/
public class TestJob implements Job {
    @Override
    public void execute()  {
        System.out.println("測(cè)試開(kāi)始測(cè)試");
        try {
            Thread.sleep(10);
            System.out.println("測(cè)試用例測(cè)試...");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}