0
我已经写了一个线程类，它的run方法将从数据库中提取某些提交的作业并执行它们。我已经在会话监听器的上下文初始化方法中启动了此线程，以便线程在我的服务器重新启动后立即启动。 在运行方法中，第一步是拾取数据库中处于“已提交”状态的所有任务，然后逐个执行它们。 我在所有任务完成后提交新任务时遇到问题执行。原本我的线程应该选择这个，但它不是。我已经检查了线程的状态，它是“RUNNABLE”。一旦我重新启动服务器，线程正在完成这个任务，但其他明智的。让一个线程运行来执行任务
public void contextInitialized(ServletContextEvent sce) {
try {
Configuration configuration = new Configuration();
configuration.configure("hibernate.cfg.xml");
ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().
applySettings(configuration.getProperties()).buildServiceRegistry();
sessionFactory = new AnnotationConfiguration().
buildSessionFactory(serviceRegistry);
logger.debug("sessionFactory created in HibernateSessionFactoryListener.contextInitialized() : " + sessionFactory);
// get servletcontext
context = sce.getServletContext();
// start session factory
context.setAttribute("datasource", sessionFactory);
isSessionActive = true;
//SubmitTaskThread t = new SubmitTaskThread();
t.start();
}
以上是在语境中的代码运行方法初始化
代码：
public void run(){
//logger1.debug("in run method of thread class");
//SubmitTask st = new SubmitTask();
//st.runJobs();
//TASKS THAT ARE SUBMITTED
try {
pendingList=getPendingList();
} catch (Exception e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
if (pendingList.size()>0){
boolean isObjStorage=false;
CornicheVO runVO;
Transfer newTransferJob;
List<String> locations;
JobVO jobSubmitVo;
for (int listSize=0;listSize<pendingList.size();listSize++){
locations = new ArrayList<String>();
runVO=pendingList.get(listSize);
newTransferJob=new Transfer();
jobSubmitVo=new JobVO();
newTransferJob.setTask_id(runVO.getTask_Id());
locations.add(runVO.getSrcLocDesc());
locations.add(runVO.getDstLocDesc());
try {
drivesInfo = getLocationInfo(locations);
} catch (CornicheException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
for (NasDrive drive : drivesInfo) {
if (drive.getSrc_loc_desc().equals(
runVO.getSrcLocDesc())) {
if ("OBJSTORAGE".equals(drive.getType())) {
isObjStorage = true;
newTransferJob.setSrc_server_type("OOSS");
} else {
newTransferJob.setSrc_server_type("NAS");
}
newTransferJob.setSrc_server(drive.getSrc_server());
newTransferJob.setSrc_server_dflt_loc(drive.getSrc_Loc());
newTransferJob.setSrc_server_id(drive.getUsr_id());
newTransferJob.setSrc_server_pswd(drive.getPswd());
} else {
if ("OBJSTORAGE".equals(drive.getType())) {
newTransferJob.setDst_server_type("OOSS");
} else {
newTransferJob.setDst_server_type("NAS");
}
newTransferJob.setDst_server(drive.getSrc_server());
newTransferJob.setDst_server_dflt_loc(drive.getSrc_Loc());
newTransferJob.setDst_server_id(drive.getUsr_id());
newTransferJob.setDst_server_pswd(drive.getPswd());
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
jobSubmitVo.setClientName(runVO.getClientName());
jobSubmitVo.setSrcServer(runVO.getSrcLoc());
jobSubmitVo.setDstServer(runVO.getDstLoc());
jobSubmitVo.setSrcServerDesc(runVO.getSrcLocDesc());
jobSubmitVo.setDstServerDesc(runVO.getDstLocDesc());
jobSubmitVo.setFileName(runVO.getFileName());
jobSubmitVo.setSizeOfFile("32");
jobSubmitVo.setUsrName(runVO.getLstUpdtIdCd());
jobSubmitVo.setMetaTag(runVO.getMetaTag());
jobSubmitVo.setRententionPeriod(runVO.getRetentionPrdcurrent());
jobSubmitVo.setTask_Id(runVO.getTask_Id());
if (!isObjStorage) {
//CURLProcessor uploader = new CURLProcessor();
// Export the scripts first
util.exportFiles(newTransferJob.getSrc_server(), newTransferJob.getSrc_server_id(),newTransferJob.getSrc_server_pswd(),newTransferJob.getSrc_server_dflt_loc());
uploadtrasnfer(newTransferJob, runVO.getFileName(), jobSubmitVo);
} else {
util.exportFiles(newTransferJob.getDst_server(), newTransferJob.getDst_server_id(),newTransferJob.getDst_server_pswd(),newTransferJob.getDst_server_dflt_loc());
downloadTrasnfer(newTransferJob, runVO.getFileName(), jobSubmitVo);
}
try {
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
我想你需要在这里发布相关的代码。没有它就很难理解什么是错的。 – Serge
很难知道没有例子的问题 – BaneDad
如果你真的想要一个答案，你需要构建一个[mcve]，这将需要很长时间，我敢肯定，因为你需要重写代码，以便我们不需要数据库来运行它并查看您的问题。但是，如果不付出努力，我看不到你的答案。 – RealSkeptic