Update AjouterThesesPersonnesProcessor.java

abes-esr · May 22, 2024 · 2bf793d · 2bf793d
1 parent 8d87701
commit 2bf793d
Showing 1 changed file with 3 additions and 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
@@ -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) {