costin 01/08/25 18:55:59
Modified: src/share/org/apache/tomcat/util/threads ThreadPool.java
Log:
Added an extra message for the first time we exceed maxThreads.
Revision Changes Path
1.6 +15 -3
jakarta-tomcat/src/share/org/apache/tomcat/util/threads/ThreadPool.java
Index: ThreadPool.java
===================================================================
RCS file:
/home/cvs/jakarta-tomcat/src/share/org/apache/tomcat/util/threads/ThreadPool.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- ThreadPool.java 2001/08/25 00:59:03 1.5
+++ ThreadPool.java 2001/08/26 01:55:59 1.6
@@ -1,7 +1,7 @@
/*
- * $Header:
/home/cvs/jakarta-tomcat/src/share/org/apache/tomcat/util/threads/ThreadPool.java,v
1.5 2001/08/25 00:59:03 nacho Exp $
- * $Revision: 1.5 $
- * $Date: 2001/08/25 00:59:03 $
+ * $Header:
/home/cvs/jakarta-tomcat/src/share/org/apache/tomcat/util/threads/ThreadPool.java,v
1.6 2001/08/26 01:55:59 costin Exp $
+ * $Revision: 1.6 $
+ * $Date: 2001/08/26 01:55:59 $
*
* ====================================================================
*
@@ -211,6 +211,7 @@
int toOpen = currentThreadCount + minSpareThreads;
openThreads(toOpen);
} else {
+ logFull(loghelper, currentThreadCount, maxThreads);
// Wait for a thread to become idel.
while(currentThreadsBusy == currentThreadCount) {
try {
@@ -239,6 +240,17 @@
currentThreadsBusy++;
}
c.runIt(r);
+ }
+
+ static boolean logfull=true;
+ public static void logFull(Log loghelper, int currentThreadCount, int
maxThreads) {
+ if( logfull ) {
+ loghelper.log("All threads are busy, waiting. Please " +
+ "increase maxThreads or check the servlet" +
+ " status" + currentThreadCount + " " +
+ maxThreads );
+ logfull=false;
+ }
}
/**
