From 2bf793d098bdedddf56d0033e09ce6456a3b02ee Mon Sep 17 00:00:00 2001
From: theo-chmbn <47857845+theo-chmbn@users.noreply.github.com>
Date: Wed, 22 May 2024 10:39:43 +0200
Subject: [PATCH] Update AjouterThesesPersonnesProcessor.java

---
 .../processor/AjouterThesesPersonnesProcessor.java          | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/fr/abes/theses_batch_indexation/processor/AjouterThesesPersonnesProcessor.java b/src/main/java/fr/abes/theses_batch_indexation/processor/AjouterThesesPersonnesProcessor.java
index 1f3cf44..a2f65b4 100644
--- a/src/main/java/fr/abes/theses_batch_indexation/processor/AjouterThesesPersonnesProcessor.java
+++ b/src/main/java/fr/abes/theses_batch_indexation/processor/AjouterThesesPersonnesProcessor.java
@@ -115,9 +115,9 @@ public TheseModel process(TheseModel theseModel) throws Exception {
 
         java.util.Set nntLies = elasticSearchUtils.getNntLies(theseModel.getId());
 
-        mutex.lock();
 
         try {
+            mutex.lock();
             log.info("Dans la liste des thesesEnTraitement  : " + thesesEnTraitement.size());
 
             while (
@@ -129,7 +129,7 @@ public TheseModel process(TheseModel theseModel) throws Exception {
             ) {
                 mutex.unlock();
                 log.info("On attends ...");
-                Thread.sleep(100);
+                Thread.sleep(200);
                 mutex.lock();
             }
             thesesEnTraitement.addAll(nntLies);
@@ -227,8 +227,8 @@ public TheseModel process(TheseModel theseModel) throws Exception {
 
         log.info("6 fin traitement");
 
-        mutex.lock();
         try {
+            mutex.lock();
             thesesEnTraitement.removeAll(nntLies);
         } catch (Exception e) {
             for (Object nnt:nntLies) {