416477 - QueuedThreadPool does not reuse interrupted threads

2013-11-11 14:06:41 +11:00 · 2013-11-11 14:06:41 +11:00 · 16d22828fd
parent f0c44ccff7
commit 16d22828fd
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
@ -535,12 +535,14 @@ public class QueuedThreadPool extends AbstractLifeCycle implements SizedThreadPo
                    startThreads(1);
                }

-                while (isRunning())
+                loop: while (isRunning())
                {
                    // Job loop
                    while (job != null && isRunning())
                    {
                        runJob(job);
+                        if (Thread.interrupted())
+                            break loop;
                        job = _jobs.poll();
                    }