Issue #7650 - Fix race condition when stopping QueuedThreadPool (#9325)

* Issue #7650 - Fix race condition when stopping QueuedThreadPool Signed-off-by: Dominik Zöchbauer <dominik@zoechbauer.info> Co-authored-by: Greg Wilkins <gregw@webtide.com> Co-authored-by: Simone Bordet <simone.bordet@gmail.com>
2023-02-08 10:27:14 +01:00 · 2023-02-08 10:27:14 +01:00 · 40f7fc8510
parent 0a4a077819
commit 40f7fc8510
1 changed files with 3 additions and 1 deletions
--- 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
@ -288,9 +288,11 @@ public class QueuedThreadPool extends ContainerLifeCycle implements ThreadFactor
        }

        // Close any un-executed jobs
-        while (!_jobs.isEmpty())
+        while (true)
        {
            Runnable job = _jobs.poll();
+            if (job == null)
+                break;
            if (job instanceof Closeable)
            {
                try