实现一个线程池
public class SjgxrwStartQuest extends AbstractQuest {
?@Override
?public void execute() throws Exception {
??//先取出所有的任务一
??List<YqxzrwBO> xzrwList = sjgxService.getXyxzrw();
??if(xzrwList==null || xzrwList.isEmpty()){
???return;
??}
??for(YqxzrwBO bo : xzrwList){
???String className = bo.getZxl();
???if(className==null || "".equals(className)){
????bo.setZt("2");
????sjgxService.updateRwzt(bo);
????continue;
???}
???bo.setCfcs(bo.getCfcs()+1);
???bo.setZt("1");
???sjgxService.updateRwzt(bo);
???AbstractIdeaDataDownload download = (AbstractIdeaDataDownload)BeanFactory.getBean(className);
???download.setYqxzrwBO(bo);
???BatchTaskThreadPoolService.singleton().execute(download);
??}
?}
?@Override
?public boolean isStart(long prevExecuteTime) throws Exception {
??if(prevExecuteTime==0){
???long now = System.currentTimeMillis();
???if(now - getSystemStartTime() < 2*60*1000){
????sjgxService.updateRwcshzt();
???}
??}
??return sjgxService.getSfczxzrw();
?}
?
?@Autowired
?private SjgxService sjgxService;
?public SjgxService getSjgxService() {
??return sjgxService;
?}
?public void setSjgxService(SjgxService sjgxService) {
??this.sjgxService = sjgxService;
?}
