change pool size

mopemope · Apr 26, 2019 · 548191a · 548191a
1 parent 1886e37
commit 548191a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/server/src/main/java/meghanada/Main.java b/server/src/main/java/meghanada/Main.java
@@ -49,7 +49,7 @@ public static String getVersion() throws IOException {
   }
 
   public static void main(String[] args) throws ParseException, IOException {
-    int size = Runtime.getRuntime().availableProcessors() + 4;
+    int size = Runtime.getRuntime().availableProcessors() * 2;
     System.setProperty(
         "java.util.concurrent.ForkJoinPool.common.parallelism", Integer.toString(size));
 

diff --git a/server/src/main/java/meghanada/system/Executor.java b/server/src/main/java/meghanada/system/Executor.java
@@ -22,16 +22,16 @@
 public class Executor {
 
   private static final Logger log = LogManager.getLogger(Executor.class);
-  private static final int PARALLELISM = 8;
 
   private static Executor executor;
   private final ExecutorService executorService;
   private final ExecutorService fixedThreadPool;
   private final EventBus eventBus;
 
   private Executor() {
+    int size = Runtime.getRuntime().availableProcessors() * 2;
     this.executorService = Executors.newCachedThreadPool();
-    this.fixedThreadPool = Executors.newFixedThreadPool(PARALLELISM);
+    this.fixedThreadPool = Executors.newFixedThreadPool(size);
     this.eventBus =
         new AsyncEventBus(
             executorService,