increase pool size

Peterkn2001 · Jan 20, 2021 · cc00de7 · cc00de7
1 parent 927fa4d
commit cc00de7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/server/core/src/main/java/cc/blynk/server/core/BlockingIOProcessor.java b/server/core/src/main/java/cc/blynk/server/core/BlockingIOProcessor.java
@@ -61,7 +61,7 @@ public BlockingIOProcessor(int poolSize, int maxQueueSize) {
                 new ArrayBlockingQueue<>(100),
                 BlynkTPFactory.build("reporting-db"));
 
-        this.dbGetServerExecutor = new ThreadPoolExecutor(poolSize / 3, poolSize / 3, 2L,
+        this.dbGetServerExecutor = new ThreadPoolExecutor(poolSize, poolSize, 2L,
                 TimeUnit.MINUTES, new ArrayBlockingQueue<>(250),
                 BlynkTPFactory.build("getServer"));
 

diff --git a/server/core/src/main/java/cc/blynk/server/db/DBManager.java b/server/core/src/main/java/cc/blynk/server/db/DBManager.java
@@ -108,7 +108,7 @@ private HikariConfig initConfig(BaseProperties serverProperties) {
 
         config.setAutoCommit(false);
         config.setConnectionTimeout(serverProperties.getLongProperty("connection.timeout.millis"));
-        config.setMaximumPoolSize(3);
+        config.setMaximumPoolSize(10);
         config.setMaxLifetime(0);
         config.setConnectionTestQuery("SELECT 1");
         return config;