From e8424eff4d308b5f54de54a198f49506cfd0c03a Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 20 Jun 2021 15:50:53 +0800 Subject: [PATCH] refactor: rename one DispatchStrategy --- .../java/tech/powerjob/common/enums/DispatchStrategy.java | 4 ++-- .../tech/powerjob/common/request/http/SaveJobInfoRequest.java | 2 +- .../main/java/tech/powerjob/server/core/DispatchService.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/powerjob-common/src/main/java/tech/powerjob/common/enums/DispatchStrategy.java b/powerjob-common/src/main/java/tech/powerjob/common/enums/DispatchStrategy.java index 23157a00..86acfce5 100644 --- a/powerjob-common/src/main/java/tech/powerjob/common/enums/DispatchStrategy.java +++ b/powerjob-common/src/main/java/tech/powerjob/common/enums/DispatchStrategy.java @@ -13,14 +13,14 @@ import lombok.Getter; @AllArgsConstructor public enum DispatchStrategy { - HEALTH_FIRST(1), + PERFORMANCE_FIRST(1), RANDOM(2); private final int v; public static DispatchStrategy of(Integer v) { if (v == null) { - return HEALTH_FIRST; + return PERFORMANCE_FIRST; } for (DispatchStrategy ds : values()) { if (v.equals(ds.v)) { diff --git a/powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java b/powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java index c394576c..8ae3ec88 100644 --- a/powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java +++ b/powerjob-common/src/main/java/tech/powerjob/common/request/http/SaveJobInfoRequest.java @@ -148,7 +148,7 @@ public class SaveJobInfoRequest { public DispatchStrategy getDispatchStrategy() { if (dispatchStrategy == null) { - return DispatchStrategy.HEALTH_FIRST; + return DispatchStrategy.PERFORMANCE_FIRST; } return dispatchStrategy; } diff --git a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/DispatchService.java b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/DispatchService.java index 8bb0d863..014eaca4 100644 --- a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/DispatchService.java +++ b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/DispatchService.java @@ -195,7 +195,7 @@ public class DispatchService { private WorkerInfo selectTaskTracker(JobInfoDO jobInfo, List workerInfos) { DispatchStrategy dispatchStrategy = DispatchStrategy.of(jobInfo.getDispatchStrategy()); switch (dispatchStrategy) { - case HEALTH_FIRST: + case PERFORMANCE_FIRST: return workerInfos.get(0); case RANDOM: return workerInfos.get(ThreadLocalRandom.current().nextInt(workerInfos.size()));