This commit is contained in:
@@ -201,7 +201,7 @@ public final class Application {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void init() throws Exception {
|
public void init() throws Exception {
|
||||||
System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "" + Runtime.getRuntime().availableProcessors() * 16);
|
System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "" + Runtime.getRuntime().availableProcessors() * 4);
|
||||||
System.setProperty("convert.bson.pool.size", "128");
|
System.setProperty("convert.bson.pool.size", "128");
|
||||||
System.setProperty("convert.json.pool.size", "128");
|
System.setProperty("convert.json.pool.size", "128");
|
||||||
System.setProperty("convert.bson.writer.buffer.defsize", "4096");
|
System.setProperty("convert.bson.writer.buffer.defsize", "4096");
|
||||||
|
|||||||
@@ -395,7 +395,7 @@ public final class EntityCache<T> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public boolean isParallel() {
|
public boolean isParallel() {
|
||||||
return this.list.size() >= 1024 * 64;
|
return this.list.size() >= 1024 * 1024;
|
||||||
}
|
}
|
||||||
|
|
||||||
private Stream<T> listStream() {
|
private Stream<T> listStream() {
|
||||||
|
|||||||
Reference in New Issue
Block a user