From a48bea6c630eb25b66db31ef0606bd98d9ee310b Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Mon, 8 Nov 2021 23:46:02 +0100 Subject: [PATCH] Fix wait time --- .../dbengine/lucene/collector/ReactiveLeafCollector.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java b/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java index b0f6dd4..62b166e 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java +++ b/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java @@ -33,8 +33,8 @@ public class ReactiveLeafCollector implements LeafCollector { LLUtils.ensureBlocking(); var scoreDoc = new ScoreDoc(leafReaderContext.docBase + i, 0, shardIndex); while (scoreDocsSink.requestedFromDownstream() < 0 && !scoreDocsSink.isCancelled()) { - // 100ms - LockSupport.parkNanos(100L * 1000000L); + // 10ms + LockSupport.parkNanos(10L * 1000000L); } scoreDocsSink.next(scoreDoc); if (scoreDocsSink.isCancelled()) {