andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Default to non-shared schedulers

Browse Source
This commit is contained in:
Andrea Cavalli 2022-10-13 00:07:24 +02:00
parent c01485158d
commit 1f672a63ef
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
View File

@ -444,7 +444,7 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa
threadCap = threadCapProperty; threadCap = threadCapProperty;
} }
} }
if (parseBoolean(System.getProperty("it.cavallium.dbengine.scheduler.write.shared", "true"))) { if (parseBoolean(System.getProperty("it.cavallium.dbengine.scheduler.write.shared", "false"))) {
this.dbWScheduler = Schedulers.boundedElastic(); this.dbWScheduler = Schedulers.boundedElastic();
} else { } else {
this.dbWScheduler = Schedulers.newBoundedElastic(threadCap, this.dbWScheduler = Schedulers.newBoundedElastic(threadCap,
@ -461,7 +461,7 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa
threadCap = threadCapProperty; threadCap = threadCapProperty;
} }
} }
if (parseBoolean(System.getProperty("it.cavallium.dbengine.scheduler.read.shared", "true"))) { if (parseBoolean(System.getProperty("it.cavallium.dbengine.scheduler.read.shared", "false"))) {
this.dbRScheduler = Schedulers.boundedElastic(); this.dbRScheduler = Schedulers.boundedElastic();
} else { } else {
this.dbRScheduler = Schedulers.newBoundedElastic(threadCap, this.dbRScheduler = Schedulers.newBoundedElastic(threadCap,