Prechádzať zdrojové kódy

优化 队列策略,大大提升性能

hugui 9 rokov pred
rodič
commit
542de83ba6

+ 1 - 1
lts-core/src/main/java/com/lts/core/constant/Constants.java

@@ -70,7 +70,7 @@ public interface Constants {
     public static final String JOB_QUEUE_KEY = "job.queue";
     // 客户端提交并发请求size
     public static final String JOB_SUBMIT_CONCURRENCY_SIZE = "job.submit.concurrency.size";
-    public static final int DEFAULT_JOB_SUBMIT_CONCURRENCY_SIZE = Constants.AVAILABLE_PROCESSOR * 4;
+    public static final int DEFAULT_JOB_SUBMIT_CONCURRENCY_SIZE = 100;
 
     public static final String PROCESSOR_THREAD = "job.processor.thread";
     public static final int DEFAULT_PROCESSOR_THREAD = 32 + AVAILABLE_PROCESSOR * 5;

+ 1 - 1
lts-core/src/main/java/com/lts/core/domain/Job.java

@@ -30,7 +30,7 @@ public class Job {
 
     private Map<String, String> extParams;
     // 是否要反馈给客户端
-    private boolean needFeedback = true;
+    private boolean needFeedback = false;
     // 重试次数
     private int retryTimes = 0;
     /**