From 7d43a7f0a3ea90a152a9d0e52fde1e0f13272c10 Mon Sep 17 00:00:00 2001
From: PC-202403201522\Administrator <1041918560@qq.com>
Date: Mon, 13 May 2024 17:37:10 +0800
Subject: [PATCH] 定时任务阻塞
---
src/main/java/com/nq/utils/task/stock/CarryPositionTask.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java b/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
index 4469cee..1178088 100644
--- a/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
+++ b/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
@@ -56,8 +56,13 @@
private final Lock subscriptionLock = new ReentrantLock();
+ boolean ballot = true;
+
@Scheduled(cron = "0 0/10 * * * ?")
public void ballot() {
+ if (ballot)
+ ballot = false;
+ else return;
if (ballotLock.tryLock()) {
try {
log.info("新股上市转持仓定时任务--------->开始");
@@ -83,14 +88,19 @@
log.error("新股上市转持仓定时任务发生异常", e);
} finally {
ballotLock.unlock();
+ ballot = true;
}
} else {
log.info("新股上市转持仓定时任务--------->上次任务还未执行完成，本次任务忽略");
}
}
+ boolean subscription = true;
@Scheduled(cron = "0 0/1 * * * ?")
public void subscription() {
+ if (subscription)
+ subscription = false;
+ else return;
if (subscriptionLock.tryLock()) {
try {
log.info("自动转已认缴--------->开始");
@@ -108,6 +118,7 @@
log.error("自动转已认缴定时任务发生异常", e);
} finally {
subscriptionLock.unlock();
+ subscription = true;
}
} else {
log.info("自动转已认缴定时任务--------->上次任务还未执行完成，本次任务忽略");
--
Gitblit v1.9.3