gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(1.5.0-beta1): 优化任务扫描性能

Browse Source
This commit is contained in:
opensnail 2025-04-02 22:41:46 +08:00
parent 340a1a1d8e
commit a4e9c87724
6 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/ScanJobTaskActor.java
View File

@ -163,7 +163,7 @@ public class ScanJobTaskActor extends AbstractActor {
return Collections.emptyList();
}
List<Job> jobs = jobMapper.selectPage(new PageDTO<>(0, systemProperties.getJobPullPageSize()),
List<Job> jobs = jobMapper.selectPage(new PageDTO<>(0, systemProperties.getJobPullPageSize(), Boolean.FALSE),
new LambdaQueryWrapper<Job>()
.select(Job::getGroupName, Job::getNextTriggerAt, Job::getBlockStrategy, Job::getTriggerType,
Job::getTriggerInterval, Job::getExecutorTimeout, Job::getTaskType, Job::getResident,

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/dispatch/ScanWorkflowTaskActor.java
View File

@ -130,7 +130,7 @@ public class ScanWorkflowTaskActor extends AbstractActor {
return Collections.emptyList();
}
List<Workflow> workflows = workflowMapper.selectPage(new PageDTO<>(0, systemProperties.getJobPullPageSize()),
List<Workflow> workflows = workflowMapper.selectPage(new PageDTO<>(0, systemProperties.getJobPullPageSize(), Boolean.FALSE),
new LambdaQueryWrapper<Workflow>()
.select(Workflow::getId, Workflow::getGroupName, Workflow::getNextTriggerAt, Workflow::getTriggerType,
Workflow::getTriggerInterval, Workflow::getExecutorTimeout, Workflow::getNamespaceId,

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/schedule/JobLogMergeSchedule.java
View File

@ -94,7 +94,7 @@ public class JobLogMergeSchedule extends AbstractSchedule implements Lifecycle {
private List<JobPartitionTaskDTO> jobTaskBatchList(Long startId, LocalDateTime endTime) {
List<JobTaskBatch> jobTaskBatchList = jobTaskBatchMapper.selectPage(
new Page<>(0, 1000),
new Page<>(0, 1000, Boolean.FALSE),
new LambdaUpdateWrapper<JobTaskBatch>()
.ge(JobTaskBatch::getId, startId)
.in(JobTaskBatch::getTaskBatchStatus, JobTaskBatchStatusEnum.COMPLETED)

2
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/dispatch/ScanRetryActor.java
View File

@ -196,7 +196,7 @@ public class ScanRetryActor extends AbstractActor {
public List<RetryPartitionTask> listAvailableTasks(Long startId, Set<Integer> buckets) {
List<Retry> retries = accessTemplate.getRetryAccess()
.listPage(new PageDTO<>(0, systemProperties.getRetryPullPageSize()),
.listPage(new PageDTO<>(0, systemProperties.getRetryPullPageSize(), Boolean.FALSE),
new LambdaQueryWrapper<Retry>()
.select(Retry::getId, Retry::getNextTriggerAt, Retry::getGroupName, Retry::getRetryCount,
Retry::getSceneName, Retry::getNamespaceId, Retry::getTaskType)

2
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/CleanerSchedule.java
View File

@ -112,7 +112,7 @@ public class CleanerSchedule extends AbstractSchedule implements Lifecycle {
private List<RetryPartitionTask> retryTaskBatchList(Long startId, LocalDateTime endTime) {
List<Retry> retryTaskList = retryMapper.selectPage(
new Page<>(0, 500),
new Page<>(0, 500, Boolean.FALSE),
new LambdaUpdateWrapper<Retry>()
.ge(Retry::getId, startId)
.le(Retry::getCreateDt, endTime)

2
snail-job-server/snail-job-server-retry-task/src/main/java/com/aizuda/snailjob/server/retry/task/support/schedule/RetryLogMergeSchedule.java
View File

@ -94,7 +94,7 @@ public class RetryLogMergeSchedule extends AbstractSchedule implements Lifecycle
private List<RetryMergePartitionTaskDTO> retryLogList(Long startId, LocalDateTime endTime) {
List<RetryTask> jobTaskBatchList = retryTaskMapper.selectPage(
new Page<>(0, 1000),
new Page<>(0, 1000, Boolean.FALSE),
new LambdaUpdateWrapper<RetryTask>()
.ge(RetryTask::getId, startId)
.in(RetryTask::getTaskStatus, Lists.newArrayList(