diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
index 2e8c780..e57964a 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalLuceneIndex.java
@@ -93,7 +93,13 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
 			new ShortNamedThreadFactory("heavy-tasks").setDaemon(true).withGroup(new ThreadGroup("lucene-heavy-tasks")),
 			Math.toIntExact(Duration.ofHours(1).toSeconds())
 	));
-	private static final Scheduler bulkScheduler = uninterruptibleScheduler(Schedulers.boundedElastic());
+	private static final Scheduler luceneWriteScheduler = uninterruptibleScheduler(Schedulers.newBoundedElastic(
+			DEFAULT_BOUNDED_ELASTIC_SIZE,
+			DEFAULT_BOUNDED_ELASTIC_QUEUESIZE,
+			new ShortNamedThreadFactory("lucene-write").setDaemon(true).withGroup(new ThreadGroup("lucene-write")),
+			Math.toIntExact(Duration.ofHours(1).toSeconds())
+	));
+	private static final Scheduler bulkScheduler = luceneWriteScheduler;
 
 	static {
 		LLUtils.initHooks();
@@ -258,7 +264,7 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
 	private <V> Mono<V> runSafe(Callable<V> callable) {
 		return Mono
 				.fromCallable(callable)
-				.subscribeOn(uninterruptibleScheduler(Schedulers.boundedElastic()))
+				.subscribeOn(luceneWriteScheduler)
 				.publishOn(Schedulers.parallel());
 	}
 
@@ -422,7 +428,7 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
 				shutdownLock.unlock();
 			}
 			return null;
-		}).subscribeOn(luceneHeavyTasksScheduler).transform(this::ensureOpen);
+		}).subscribeOn(luceneHeavyTasksScheduler).publishOn(Schedulers.parallel()).transform(this::ensureOpen);
 	}
 
 	@Override