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/StockTask.java | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/nq/utils/task/stock/StockTask.java b/src/main/java/com/nq/utils/task/stock/StockTask.java
index 90967b3..619e482 100644
--- a/src/main/java/com/nq/utils/task/stock/StockTask.java
+++ b/src/main/java/com/nq/utils/task/stock/StockTask.java
@@ -61,16 +61,16 @@
*/
@Scheduled(cron = "0 0 0/2 * * ?")
public void syncINStockData() {
- if (syncINStockData)
- syncINStockData = false;
- else return;
+ if (syncINStockData) // 定义一个布尔变量，代表新闻任务是否在处理中
+ return;
+ syncINStockData = true;
if (syncINStockDataLock.tryLock()) {
try {
loadAllStock(EStockType.IN);
// loadAllStock(EStockType.HK);
} finally {
syncINStockDataLock.unlock();
- syncINStockData = true;
+ syncINStockData = false;
}
}
}
@@ -177,9 +177,9 @@
*/
@Scheduled(cron = "0/1 * * * * ?")
public void stockConstraint() {
- if (stockConstraint)
- stockConstraint = false;
- else return;
+ if (stockConstraint) // 定义一个布尔变量，代表新闻任务是否在处理中
+ return;
+ stockConstraint = true;
if (stockConstraintLock.tryLock()) {
try {
List<UserPosition> userPositions = userPositionMapper.selectList(new LambdaQueryWrapper<UserPosition>().isNull(UserPosition::getSellOrderId));
@@ -191,7 +191,7 @@
log.error("强制平仓任务错误：" + e.getMessage());
} finally {
stockConstraintLock.unlock();
- stockConstraint = true;
+ stockConstraint = false;
}
} else {
log.info("强制平仓任务--------->上次任务还未执行完成，本次任务忽略");
--
Gitblit v1.9.3