Limit max threads in pool. Use unbounded queue to pending tanks.

Author: mstyura

objectbox-java/src/main/java/io/objectbox/BoxStoreBuilder.java

@@ -93,7 +93,7 @@ public class BoxStoreBuilder {
 
     int threadPoolCoreSize = 0;
 
-    int threadPoolMaxSize = Integer.MAX_VALUE;
+    int threadPoolMaxSize = Math.min(64, Runtime.getRuntime().availableProcessors());
 
     int threadPoolThreadKeepAliveSeconds = 20;
 

objectbox-java/src/main/java/io/objectbox/internal/ObjectBoxThreadPool.java

@@ -17,7 +17,7 @@
 package io.objectbox.internal;
 
 import java.util.concurrent.Executors;
-import java.util.concurrent.SynchronousQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -40,7 +40,7 @@ public class ObjectBoxThreadPool extends ThreadPoolExecutor {
     private final BoxStore boxStore;
 
     public ObjectBoxThreadPool(BoxStore boxStore, int corePoolSize, int maximumPoolSize, int threadKeepAliveSeconds) {
-        super(corePoolSize, maximumPoolSize, threadKeepAliveSeconds, TimeUnit.SECONDS, new SynchronousQueue<>(),
+        super(corePoolSize, maximumPoolSize, threadKeepAliveSeconds, TimeUnit.SECONDS, new LinkedBlockingQueue<>(),
                 new ObjectBoxThreadFactory());
         this.boxStore = boxStore;
     }