diff --git a/AprEndpoint.java b/AprEndpoint.mine index 5b98225..7eb9a70 100644 --- src/java/org/apache/tomcat/util/net/AprEndpoint.java +++ src/java/org/apache/tomcat/util/net/AprEndpoint.java @@ -169,7 +169,7 @@ public class AprEndpoint { * Maximum amount of worker threads. */ protected int maxThreads = 200; - public void setMaxThreads(int maxThreads) { this.maxThreads = maxThreads; } + public void setMaxThreads(int maxThreads) { this.maxThreads = maxThreads; this.workers.resizeTo(maxThreads); } public int getMaxThreads() { return maxThreads; } @@ -2442,6 +2442,16 @@ public class AprEndpoint { public int size() { return (end); } + + /** + * Resize the queue + * @param newSize + */ + public void resizeTo(int newSize){ + Worker[] newWorkers = new Worker[newSize]; + System.arraycopy(workers, 0, newWorkers, 0, workers.length); + this.workers = newWorkers; + } }