| | |
|---|
| | | if(threadPoolPriority != null && threadPoolPriority.intValue() >= 0){ |
|---|
| | | pro.put("org.quartz.threadPool.threadPriority", "" + (threadPoolPriority==null?5:(threadPoolPriority<=0?5:threadPoolPriority))); |
|---|
| | | } |
|---|
| | | if(threadPoolMaxCount != null && threadPoolPriority != null){ |
|---|
| | | if(threadPoolMaxCount.intValue() < threadPoolPriority.intValue()){ |
|---|
| | | throw new SchedulerException("threadPoolMaxCount必须大于等于threadPoolPriority") ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | scheduler = new StdSchedulerFactory(pro).getScheduler(); |
|---|
| | | } catch (SchedulerException e) { |
|---|
| | | log.error(e) ; |
|---|
