newThread(newRunnable(){@Overridepublicvoidrun(){//spring无法处理thread的事务,声明式事务无效DefaultTransactionDefinitiondef=newDefaultTransactionDefinition();def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);PlatformTransactionManagertxManager=ContextLoader.getCurrentWebApplicationContext().getBean(PlatformTransactionManager.class);TransactionStatusstatus=txManager.getTransaction(def);try{processEachPlan(learn);txManager.commit(status);//提交事务}catch(Exceptione){Logger.info("异常信息:"+e.toString());txManager.rollback(status);//回滚事务}}}).start();