diff --git a/src/com/wentch/redkale/boot/Application.java b/src/com/wentch/redkale/boot/Application.java index de88c4b32..d1a71fab6 100644 --- a/src/com/wentch/redkale/boot/Application.java +++ b/src/com/wentch/redkale/boot/Application.java @@ -34,7 +34,7 @@ import org.w3c.dom.*; * 进程启动类,程序启动后读取application.xml,进行classpath扫描动态加载Service与Servlet * 优先加载所有SNCP协议的服务, 再加载其他协议服务, * 最后进行Service、Servlet与其他资源之间的依赖注入。 - * + * * * @author zhangjx */ @@ -201,6 +201,7 @@ public final class Application { } public void init() throws Exception { + System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "" + Runtime.getRuntime().availableProcessors() * 16); System.setProperty("convert.bson.pool.size", "128"); System.setProperty("convert.json.pool.size", "128"); System.setProperty("convert.bson.writer.buffer.defsize", "4096"); diff --git a/src/com/wentch/redkale/source/EntityCache.java b/src/com/wentch/redkale/source/EntityCache.java index 571ef5d14..b76c734c9 100644 --- a/src/com/wentch/redkale/source/EntityCache.java +++ b/src/com/wentch/redkale/source/EntityCache.java @@ -395,7 +395,7 @@ public final class EntityCache { } public boolean isParallel() { - return this.list.size() > 1024 * 1024; + return this.list.size() >= 1024 * 64; } private Stream listStream() {