From 5259432d9a97529cf1ec2be5489a5b592bee78c4 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 14 May 2024 23:51:21 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/utils/task/stock/CarryPositionTask.java | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 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 1178088..5c1ec31 100644
--- a/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
+++ b/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
@@ -60,9 +60,9 @@
@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("新股上市转持仓定时任务--------->开始");
@@ -88,7 +88,7 @@
log.error("新股上市转持仓定时任务发生异常", e);
} finally {
ballotLock.unlock();
- ballot = true;
+ ballot = false;
}
} else {
log.info("新股上市转持仓定时任务--------->上次任务还未执行完成，本次任务忽略");
@@ -98,9 +98,9 @@
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("自动转已认缴--------->开始");
@@ -118,7 +118,7 @@
log.error("自动转已认缴定时任务发生异常", e);
} finally {
subscriptionLock.unlock();
- subscription = true;
+ subscription = false;
}
} else {
log.info("自动转已认缴定时任务--------->上次任务还未执行完成，本次任务忽略");
--
Gitblit v1.9.3