From cfa9187fbf8ff981b281a92d92ec6221003c43b2 Mon Sep 17 00:00:00 2001 From: Evgeniy Cheban Date: Tue, 27 Oct 2026 05:51:33 +0200 Subject: [PATCH] Polish gh-152 --- .../reindexer/ReindexerNamespace.java | 23 ++++++++----------- 1 file changed, 9 insertions(+), 14 deletions(-) diff --git a/src/main/java/ru/rt/restream/reindexer/ReindexerNamespace.java b/src/main/java/ru/rt/restream/reindexer/ReindexerNamespace.java index 19bef24..c9ca250 100644 --- a/src/main/java/ru/rt/restream/reindexer/ReindexerNamespace.java +++ b/src/main/java/ru/rt/restream/reindexer/ReindexerNamespace.java @@ -29,7 +29,6 @@ import ru.rt.restream.reindexer.util.BeanPropertyUtils; import java.util.ArrayList; -import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -248,11 +247,16 @@ void registerPrecept(ReindexerPrecept precept) { PreceptExpression[] getPrecepts(Object item, int format) { Predicate isNullPredicate = getIsNullPredicate(item, format); - List precepts = new ArrayList<>(); - for (ReindexerPrecept precept : getPrecepts()) { - applyPrecept(precept, isNullPredicate, precepts); + List result = new ArrayList<>(); + lock.readLock().lock(); + try { + for (ReindexerPrecept precept : precepts.values()) { + applyPrecept(precept, isNullPredicate, result); + } + } finally { + lock.readLock().unlock(); } - return precepts.toArray(new PreceptExpression[0]); + return result.toArray(new PreceptExpression[0]); } private Predicate getIsNullPredicate(Object item, int format) { @@ -267,15 +271,6 @@ private Predicate getIsNullPredicate(Object item, int format) return it -> BeanPropertyUtils.getProperty(item, it.getFieldPath()) == null; } - private Collection getPrecepts() { - lock.readLock().lock(); - try { - return precepts.values(); - } finally { - lock.readLock().unlock(); - } - } - private void applyPrecept(ReindexerPrecept precept, Predicate isNullPredicate, List precepts) { // Apply precept according to the strategy.