Merge pull request #559 from sumeetphadnis/master

Allow setting of a higher `corePoolSize` while creating new `ScheduledThreadPoolExecutor`
jpos · Aug 9, 2023 · 8febf01 · 8febf01
2 parents 9b0024f + b0b3669
commit 8febf01
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/jpos/src/main/java/org/jpos/q2/QBeanSupport.java b/jpos/src/main/java/org/jpos/q2/QBeanSupport.java
@@ -255,8 +255,9 @@ protected void stopService()    throws Exception {}
     protected void destroyService() throws Exception {}
 
     protected synchronized ScheduledThreadPoolExecutor getScheduledThreadPoolExecutor() {
+        int corePoolSize = cfg.getInt("stpe-core-pool-size", 1);
         if (scheduledThreadPoolExecutor == null)
-            scheduledThreadPoolExecutor = ConcurrentUtil.newScheduledThreadPoolExecutor();
+            scheduledThreadPoolExecutor = ConcurrentUtil.newScheduledThreadPoolExecutor(corePoolSize);
         return scheduledThreadPoolExecutor;
     }
 

diff --git a/jpos/src/main/java/org/jpos/util/ConcurrentUtil.java b/jpos/src/main/java/org/jpos/util/ConcurrentUtil.java
@@ -23,7 +23,10 @@
 
 public class ConcurrentUtil {
     public static ScheduledThreadPoolExecutor newScheduledThreadPoolExecutor() {
-        ScheduledThreadPoolExecutor stpe = new ScheduledThreadPoolExecutor(1,
+        return newScheduledThreadPoolExecutor(1);
+    }
+    public static ScheduledThreadPoolExecutor newScheduledThreadPoolExecutor(int corePoolSize) {
+        ScheduledThreadPoolExecutor stpe = new ScheduledThreadPoolExecutor(corePoolSize,
           r -> {
               Thread t = Executors.defaultThreadFactory().newThread(r);
               t.setDaemon(true);