KH/kh-device-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【fix sonar】 JobLogReportHelper.java文件

Browse Source
This commit is contained in:
tianwenbo
2023-03-10 16:17:46 +08:00
parent c772f479fb
commit 703c42c936
1 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jero-boot/jero-cloud-module/jero-cloud-xxljob/src/main/java/com/xxl/job/admin/core/thread/JobLogReportHelper.java
+3 -8
View File
@@ -28,10 +28,7 @@ public class JobLogReportHelper {
private Thread logrThread; private Thread logrThread;
private volatile boolean toStop = false; private volatile boolean toStop = false;
public void start(){ public void start(){
logrThread = new Thread(new Runnable() { logrThread = new Thread(()-> {
@Override
public void run() {
// last clean log time // last clean log time
long lastCleanLogTime = 0; long lastCleanLogTime = 0;
@@ -110,10 +107,10 @@ public class JobLogReportHelper {
List<Long> logIds = null; List<Long> logIds = null;
do { do {
logIds = XxlJobAdminConfig.getAdminConfig().getXxlJobLogDao().findClearLogIds(0, 0, clearBeforeTime, 0, 1000); logIds = XxlJobAdminConfig.getAdminConfig().getXxlJobLogDao().findClearLogIds(0, 0, clearBeforeTime, 0, 1000);
if (logIds!=null && logIds.size()>0) { if (logIds!=null && !logIds.isEmpty()) {
XxlJobAdminConfig.getAdminConfig().getXxlJobLogDao().clearLog(logIds); XxlJobAdminConfig.getAdminConfig().getXxlJobLogDao().clearLog(logIds);
} }
} while (logIds!=null && logIds.size()>0); } while (logIds!=null && !logIds.isEmpty());
// update clean time // update clean time
lastCleanLogTime = System.currentTimeMillis(); lastCleanLogTime = System.currentTimeMillis();
@@ -130,8 +127,6 @@ public class JobLogReportHelper {
} }
logger.info(">>>>>>>>>>> xxl-job, job log report thread stop"); logger.info(">>>>>>>>>>> xxl-job, job log report thread stop");
}
}); });
logrThread.setDaemon(true); logrThread.setDaemon(true);
logrThread.setName("xxl-job, admin JobLogReportHelper"); logrThread.setName("xxl-job, admin JobLogReportHelper");