ExecutorService线程池的例子

《ExecutorService线程池的例子》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、ExecutorService线程池的例子1.问题场景考试系统中，当考试结束交卷的同时需要自动批改客观题的答案，由于同时交卷的人数太多，交卷业务会变得很慢，需要等待较长时间，或者服务器容易负载过大而崩溃，因此需要使用线程池和Queue配合来实现这一工作。大体思路如下：1）每当有学生交卷时，先将学生的答题卡信息（AnswerCard）存入一个全局的Queue。这个操作不涉及数据库读写，会比直接存数据库更快的完成，学生可以很快看到交卷成功，但实际上这时学生交卷并没有完成，只是暂时保存了其答题结果。2）后台线程池创建5个线程，不断的判断Queue中是否有值，若

2、有值，则一个线程从Queue中取出一个值（AnswerCard对象）进行自动批改，并将批改完成的答题卡存入数据库。2.程序实现服务启动时立即创建并执行两个线程，一个线程池用于执行自动批改交卷任务，一个清理线程用于定期清理批改过程中产生的垃圾，防止随着时间增加造成内存溢出。批改产生的垃圾是指批改时在内存中存放的Paper（试卷）信息，用于对答题卡内容正确与否进行对比赋分，因为每场考试可能有上百个学生同时交卷，但是正确答案只有一份，因此不需要每次批改时都从数据库中去取一次paper的标准答案进行对比，每次只需取出一个paper对象存入内存，对其他的答题卡进行

3、批改时，直接从内存中获取就可以，基本思路如下：（1）创建一个全局的Map，Map的key存放考试的examId，value存放一个自定义的数据结构ExamBean（Paperpaper，Datetime）。paper是考是关联的试卷，包含标准答案、每题分数等，用于对学生答题卡进行批改赋分的主要对象；time存放考试的结束时间，用于清理线程判断该Map是否已经过期，程序中设置当考试时间过去10小时后即清理对应的Map，防止时间长了内存溢出。（2）当工作线程从Queue中取到一张答题卡进行批改时，会首先根据考试的examId从Map中查

4、找ExamBean，若Map中没有对应的key，则新建一个，并从数据库中查询对应的paper和time组成ExamBean存入Map，此操作对于每个考试只执行一次。（3）清理线程定期检查Map，若Map中存在过期的元素，则remove掉。下面是具体的实现：1）创建一个监听的类GradeListener.java，继承ServletContextListener，如下：packagecom.geariot.platform.exam.utils;importjava.util.Map;importjava.util.concurrent.BlockingQ

5、ueue;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.LinkedBlockingQueue;importjava.util.concurrent.TimeUnit;importjavax.servlet.ServletContextEvent;importjavax.servlet.ServletContextListener;importnet.sf.ehcache.store.ch

6、m.ConcurrentHashMap;importorg.apache.log4j.Logger;importorg.springframework.web.context.WebApplicationContext;importorg.springframework.web.context.support.WebApplicationContextUtils;importcom.geariot.platform.exam.dao.AnswerCardDao;importcom.geariot.platform.exam.entities.Answer

7、Card;importcom.geariot.platform.exam.model.ExamBean;importcom.geariot.platform.exam.service.ExamService;importcom.geariot.platform.exam.service.PaperService;publicclassGradeListenerimplementsServletContextListener{Loggerlog=Logger.getLogger(GradeListener.class);//创建线程池privateExec

8、utorServiceservice;//创建清理线程privateCleane