Issue #4122 QueuedThreadPool

Always clear the interrupted status Signed-off-by: Greg Wilkins <gregw@webtide.com>
jetty · Oct 2, 2019 · c37a4ff · c37a4ff
1 parent 3ad6780
commit c37a4ff
Showing 1 changed file with 5 additions and 3 deletions.
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
@@ -922,9 +922,6 @@ else if (_counts.getHi() == Integer.MIN_VALUE)
                         runJob(job);
                         if (LOG.isDebugEnabled())
                             LOG.debug("ran {} in {}", job, QueuedThreadPool.this);
-
-                        // Clear any interrupted status
-                        Thread.interrupted();
                     }
                     catch (InterruptedException e)
                     {
@@ -936,6 +933,11 @@ else if (_counts.getHi() == Integer.MIN_VALUE)
                     {
                         LOG.warn(e);
                     }
+                    finally
+                    {
+                        // Clear any interrupted status
+                        Thread.interrupted();
+                    }
                 }
             }
             finally