From 1f672a63efa99ab8f3c9882a932f194d6476acfc Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Thu, 13 Oct 2022 00:07:24 +0200 Subject: [PATCH] Default to non-shared schedulers --- .../dbengine/database/disk/LLLocalKeyValueDatabase.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java index a765a92..a699c95 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java @@ -444,7 +444,7 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa 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(); } else { this.dbWScheduler = Schedulers.newBoundedElastic(threadCap, @@ -461,7 +461,7 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa 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(); } else { this.dbRScheduler = Schedulers.newBoundedElastic(threadCap,