From 87f260d25abff8eed28471e0ab11650c8f3e3ebe Mon Sep 17 00:00:00 2001 From: redkale Date: Sun, 1 Oct 2023 07:01:38 +0800 Subject: [PATCH] =?UTF-8?q?=E9=BB=98=E8=AE=A4=E7=BA=BF=E7=A8=8B=E6=B1=A0?= =?UTF-8?q?=E5=A4=A7=E5=B0=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/source/AbstractDataSource.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redkale/source/AbstractDataSource.java b/src/main/java/org/redkale/source/AbstractDataSource.java index 6f43f7e47..0dd7ebccc 100644 --- a/src/main/java/org/redkale/source/AbstractDataSource.java +++ b/src/main/java/org/redkale/source/AbstractDataSource.java @@ -128,9 +128,9 @@ public abstract class AbstractDataSource extends AbstractService implements Data public void init(AnyValue conf) { super.init(conf); 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 { - 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())); } }