From e429c6f59e31cb217b305b69ce26adae5254e8fd Mon Sep 17 00:00:00 2001
From: ocean23 <43363687@qq.com>
Date: Sat, 16 Jan 2021 17:14:10 +0800
Subject: [PATCH] fix: modify by suggestion

---
 .../worker/core/tracker/processor/ProcessorTracker.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
index b55fb163..1dd980d0 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
@@ -343,15 +343,13 @@ public class ProcessorTracker {
         if (executeType == ExecuteType.MAP_REDUCE || executeType == ExecuteType.MAP) {
             return instanceInfo.getThreadConcurrency();
         }
-        boolean exeStandalone = executeType == ExecuteType.STANDALONE;
-        boolean fixedJob = TimeExpressionType.frequentTypes.contains(instanceInfo.getTimeExpressionType());
-        if (exeStandalone && fixedJob) {
-            return instanceInfo.getThreadConcurrency();
-        }
         // 脚本类自带线程池，不过为了少一点逻辑判断，还是象征性分配一个线程
         if (processorType == ProcessorType.PYTHON || processorType == ProcessorType.SHELL) {
             return 1;
         }
+        if (TimeExpressionType.frequentTypes.contains(instanceInfo.getTimeExpressionType())) {
+            return instanceInfo.getThreadConcurrency();
+        }
         return 2;
     }