| | |
| | | |
| | | @Scheduled(cron = "0 0/10 * * * ?") |
| | | public void ballot() { |
| | | if (ballot) |
| | | ballot = false; |
| | | else return; |
| | | if (ballot) // 定义一个布尔变量,代表新闻任务是否在处理中 |
| | | return; |
| | | ballot = true; |
| | | if (ballotLock.tryLock()) { |
| | | try { |
| | | log.info("新股上市转持仓定时任务--------->开始"); |
| | |
| | | log.error("新股上市转持仓定时任务发生异常", e); |
| | | } finally { |
| | | ballotLock.unlock(); |
| | | ballot = true; |
| | | ballot = false; |
| | | } |
| | | } else { |
| | | log.info("新股上市转持仓定时任务--------->上次任务还未执行完成,本次任务忽略"); |
| | |
| | | boolean subscription = true; |
| | | @Scheduled(cron = "0 0/1 * * * ?") |
| | | public void subscription() { |
| | | if (subscription) |
| | | subscription = false; |
| | | else return; |
| | | if (subscription) // 定义一个布尔变量,代表新闻任务是否在处理中 |
| | | return; |
| | | subscription = true; |
| | | if (subscriptionLock.tryLock()) { |
| | | try { |
| | | log.info("自动转已认缴--------->开始"); |
| | |
| | | log.error("自动转已认缴定时任务发生异常", e); |
| | | } finally { |
| | | subscriptionLock.unlock(); |
| | | subscription = true; |
| | | subscription = false; |
| | | } |
| | | } else { |
| | | log.info("自动转已认缴定时任务--------->上次任务还未执行完成,本次任务忽略"); |