From: fhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Date: Tue, 9 Jun 2009 18:51:07 +0000 (+0000)
Subject: Revert http://svn.apache.org/viewvc?view=rev&revision=763566
X-Git-Url: https://git.internetallee.de/?a=commitdiff_plain;h=5fc7f06a5686e532a1cb5c71a8339b83ce57ee19;p=tomcat7.0

Revert svn.apache.org/viewvc?view=rev&revision=763566
The code is not the same as it was before. The patch applied, while it looks the same will grow the pool the max threads even though it doesn't need to



git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@783094 13f79535-47bb-0310-9956-ffa450edef68
---

diff --git a/java/org/apache/tomcat/util/threads/TaskQueue.java b/java/org/apache/tomcat/util/threads/TaskQueue.java
index fc579e789..707776ca1 100644
--- a/java/org/apache/tomcat/util/threads/TaskQueue.java
+++ b/java/org/apache/tomcat/util/threads/TaskQueue.java
@@ -59,13 +59,15 @@ public class TaskQueue extends LinkedBlockingQueue<Runnable> {
     }
 
     public boolean offer(Runnable o) {
-        if (parent != null && parent.getPoolSize()<parent.getMaximumPoolSize()){
-        	return false;
-        } else {
-            //if we reached here, we need to add it to the queue
-            //or can't do any checks
-            return super.offer(o);
-        }
-
+      //we can't do any checks
+        if (parent==null) return super.offer(o);
+        //we are maxed out on threads, simply queue the object
+        if (parent.getPoolSize() == parent.getMaximumPoolSize()) return super.offer(o);
+        //we have idle threads, just add it to the queue
+        if (parent.getActiveCount()<(parent.getPoolSize())) return super.offer(o);
+        //if we have less threads than maximum force creation of a new thread
+        if (parent.getPoolSize()<parent.getMaximumPoolSize()) return false;
+        //if we reached here, we need to add it to the queue
+        return super.offer(o);
     }
 }