Issue #4122 QueuedThreadPool

Always clear the interrupted status Signed-off-by: Greg Wilkins <gregw@webtide.com>
2019-10-02 15:25:20 +10:00 · 2019-10-02 15:25:20 +10:00 · c37a4ff99d
parent 3ad6780b27
commit c37a4ff99d
1 changed files with 5 additions and 3 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
@ -922,9 +922,6 @@ public class QueuedThreadPool extends ContainerLifeCycle implements SizedThreadP
                        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 @@ public class QueuedThreadPool extends ContainerLifeCycle implements SizedThreadP
                    {
                        LOG.warn(e);
                    }
+                    finally
+                    {
+                        // Clear any interrupted status
+                        Thread.interrupted();
+                    }
                }
            }
            finally