[tomcat] branch 9.0.x updated: Start all core threads when starting the receiver and dispatch interceptor

[kfujino]

This is an automated email from the ASF dual-hosted git repository.

kfujino pushed a commit to branch 9.0.x
in repository https://gitbox.apache.org/repos/asf/tomcat.git


The following commit(s) were added to refs/heads/9.0.x by this push:
     new 1763385  Start all core threads when starting the receiver and 
dispatch interceptor
1763385 is described below

commit 176338583c59342663a18f035ee9a142ae5fad6a
Author: KeiichiFujino <kfuj...@apache.org>
AuthorDate: Wed Dec 2 21:54:39 2020 +0900

    Start all core threads when starting the receiver and dispatch interceptor
---
 java/org/apache/catalina/tribes/util/ExecutorFactory.java | 4 ++++
 webapps/docs/changelog.xml                                | 8 ++++++++
 2 files changed, 12 insertions(+)

diff --git a/java/org/apache/catalina/tribes/util/ExecutorFactory.java 
b/java/org/apache/catalina/tribes/util/ExecutorFactory.java
index 5fe0aee..b1241cf 100644
--- a/java/org/apache/catalina/tribes/util/ExecutorFactory.java
+++ b/java/org/apache/catalina/tribes/util/ExecutorFactory.java
@@ -47,19 +47,23 @@ public class ExecutorFactory {
     private static class TribesThreadPoolExecutor extends ThreadPoolExecutor {
         public TribesThreadPoolExecutor(int corePoolSize, int maximumPoolSize, 
long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, 
RejectedExecutionHandler handler) {
             super(corePoolSize, maximumPoolSize, keepAliveTime, unit, 
workQueue, handler);
+            prestartAllCoreThreads();
         }
 
         public TribesThreadPoolExecutor(int corePoolSize, int maximumPoolSize, 
long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, 
ThreadFactory threadFactory,
                 RejectedExecutionHandler handler) {
             super(corePoolSize, maximumPoolSize, keepAliveTime, unit, 
workQueue, threadFactory, handler);
+            prestartAllCoreThreads();
         }
 
         public TribesThreadPoolExecutor(int corePoolSize, int maximumPoolSize, 
long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, 
ThreadFactory threadFactory) {
             super(corePoolSize, maximumPoolSize, keepAliveTime, unit, 
workQueue, threadFactory);
+            prestartAllCoreThreads();
         }
 
         public TribesThreadPoolExecutor(int corePoolSize, int maximumPoolSize, 
long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
             super(corePoolSize, maximumPoolSize, keepAliveTime, unit, 
workQueue);
+            prestartAllCoreThreads();
         }
 
         @Override
diff --git a/webapps/docs/changelog.xml b/webapps/docs/changelog.xml
index 56a4b14..4f3821a 100644
--- a/webapps/docs/changelog.xml
+++ b/webapps/docs/changelog.xml
@@ -157,6 +157,14 @@
       </fix>
     </changelog>
   </subsection>
+  <subsection name="Tribes">
+    <changelog>
+      <scode>
+        Start all core threads when starting the receiver and dispatch
+        interceptor. (kfujino)
+      </scode>
+    </changelog>
+  </subsection>
   <subsection name="Other">
     <changelog>
       <update>


---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org