remove debug message in BurstExecutor

jenkinsci · Aug 30, 2021 · f677a33 · f677a33
1 parent 4c9a069
commit f677a33
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/org/jenkinsci/plugins/lucene/search/databackend/BurstExecutor.java b/src/main/java/org/jenkinsci/plugins/lucene/search/databackend/BurstExecutor.java
@@ -48,20 +48,17 @@ private class WorkerThread extends Thread {
         @Override
         public void run() {
             try {
-                LOGGER.debug("Started thread " + getName());
                 while (!workQueue.isEmpty()) {
                     try {
                         T poll = workQueue.poll(1000, TimeUnit.MILLISECONDS);
                         if (poll != null) {
-                            LOGGER.debug("Procesing with thread " + getName());
                             worker.run(poll);
                         }
                     } catch (Exception e) {
                         LOGGER.error("WorkerThread " + getName() + " exception", e);
                     }
                 }
             } finally {
-                LOGGER.debug("Quit thread " + getName());
                 removeThread(this);
             }
         }
@@ -71,6 +68,9 @@ public void waitForCompletion() throws InterruptedException {
         if (!started) {
             throw new IllegalStateException("Not started yet");
         }
+        while (!workQueue.isEmpty()) {
+            worker.run(workQueue.poll());
+        }
         ensureEnoughThreadToFinishJob();
         WorkerThread workerThread;
         while ((workerThread = getFirstWorkerThread()) != null) {