Issue jetty#7650 - Fix race condition when stopping QueuedThreadPool

Signed-off-by: Dominik Zöchbauer <[email protected]>
dzoech · Feb 3, 2023 · f54fa7f · f54fa7f
1 parent 2f431ff
commit f54fa7f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/jetty-util/src/main/java/org/eclipse/jetty/util/thread/QueuedThreadPool.java b/jetty-util/src/main/java/org/eclipse/jetty/util/thread/QueuedThreadPool.java
@@ -280,9 +280,13 @@ protected void doStop() throws Exception
         }
 
         // Close any un-executed jobs
-        while (!_jobs.isEmpty())
+        while (true)
         {
             Runnable job = _jobs.poll();
+            if (job == null)
+            {
+                break;
+            }
             if (job instanceof Closeable)
             {
                 try