lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

默认线程池大小

Browse Source
This commit is contained in:
redkale
2023-10-01 07:01:38 +08:00
parent dbf4c2e8ca
commit 87f260d25a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/redkale/source/AbstractDataSource.java
View File

@@ -128,9 +128,9 @@ public abstract class AbstractDataSource extends AbstractService implements Data
public void init(AnyValue conf) { public void init(AnyValue conf) {
super.init(conf); super.init(conf);
if (conf.getAnyValue("read") == null) { if (conf.getAnyValue("read") == null) {
this.sourceThreads = conf.getIntValue(DATA_SOURCE_THREADS, Utility.cpus()); this.sourceThreads = conf.getIntValue(DATA_SOURCE_THREADS, conf.getIntValue(DATA_SOURCE_MAXCONNS, Utility.cpus()));
} else { } else {
this.sourceThreads = conf.getAnyValue("read").getIntValue(DATA_SOURCE_THREADS, Utility.cpus()); this.sourceThreads = conf.getAnyValue("read").getIntValue(DATA_SOURCE_THREADS, conf.getIntValue(DATA_SOURCE_MAXCONNS, Utility.cpus()));
} }
} }