github-cloud
diff --git a/‎src/main/java/com/cloudbees/jenkins/GitHubPushTrigger.java
Lines changed: 39 additions & 5 deletions b/‎src/main/java/com/cloudbees/jenkins/GitHubPushTrigger.java
Lines changed: 39 additions & 5 deletions
@@ -11,13 +11,16 @@
 import hudson.model.Item;
 import hudson.model.Job;
 import hudson.model.Project;
+import hudson.triggers.SCMTrigger;
 import hudson.triggers.Trigger;
 import hudson.triggers.TriggerDescriptor;
 import hudson.util.FormValidation;
+import hudson.util.NamingThreadFactory;
 import hudson.util.SequentialExecutionQueue;
 import hudson.util.StreamTaskListener;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
 import jenkins.model.Jenkins;
-import jenkins.model.Jenkins.MasterComputer;
 import jenkins.model.ParameterizedJobMixIn;
 import jenkins.triggers.SCMTriggerItem.SCMTriggerItems;
 import org.apache.commons.jelly.XMLOutput;
@@ -45,7 +48,6 @@
 import java.util.Set;
 
 import static org.apache.commons.lang3.StringUtils.isEmpty;
-import static org.jenkinsci.plugins.github.Messages.github_trigger_check_method_warning_details;
 import static org.jenkinsci.plugins.github.util.JobInfoHelpers.asParameterizedJobMixIn;
 
 /**
@@ -72,7 +74,9 @@ public void onPost() {
      */
     public void onPost(String triggeredByUser) {
         final String pushBy = triggeredByUser;
-        getDescriptor().queue.execute(new Runnable() {
+        DescriptorImpl d = getDescriptor();
+        d.checkThreadPoolSizeAndUpdateIfNecessary();
+        d.queue.execute(new Runnable() {
             private boolean runPolling() {
                 try {
                     StreamTaskListener listener = new StreamTaskListener(getLogFile());
@@ -226,7 +230,7 @@ public void writeLogTo(XMLOutput out) throws IOException {
     @Extension
     public static class DescriptorImpl extends TriggerDescriptor {
         private final transient SequentialExecutionQueue queue =
-                new SequentialExecutionQueue(MasterComputer.threadPoolForRemoting);
+                new SequentialExecutionQueue(Executors.newSingleThreadExecutor(threadFactory()));
 
         private transient String hookUrl;
 
@@ -235,6 +239,32 @@ public static class DescriptorImpl extends TriggerDescriptor {
         @Inject
         private transient GitHubHookRegisterProblemMonitor monitor;
 
+        @Inject
+        private transient SCMTrigger.DescriptorImpl scmTrigger;
+
+        private transient int maximumThreads = Integer.MIN_VALUE;
+
+        public DescriptorImpl() {
+            checkThreadPoolSizeAndUpdateIfNecessary();
+        }
+
+        /**
+         * Update the {@link java.util.concurrent.ExecutorService} instance.
+         */
+        /*package*/
+        synchronized void checkThreadPoolSizeAndUpdateIfNecessary() {
+            if (scmTrigger != null) {
+                int count = scmTrigger.getPollingThreadCount();
+                if (maximumThreads != count) {
+                    maximumThreads = count;
+                    queue.setExecutors(
+                            (count == 0
+                                    ? Executors.newCachedThreadPool(threadFactory())
+                                    : Executors.newFixedThreadPool(maximumThreads, threadFactory())));
+                }
+            }
+        }
+
         @Override
         public boolean isApplicable(Item item) {
             return item instanceof Job && SCMTriggerItems.asSCMTriggerItem(item) != null
@@ -333,6 +363,10 @@ public static boolean allowsHookUrlOverride() {
             return ALLOW_HOOKURL_OVERRIDE;
         }
 
+        private static ThreadFactory threadFactory() {
+            return new NamingThreadFactory(Executors.defaultThreadFactory(), "GitHubPushTrigger");
+        }
+
         /**
          * Checks that repo defined in this job is not in administrative monitor as failed to be registered.
          * If that so, shows warning with some instructions
@@ -351,7 +385,7 @@ public FormValidation doCheckHookRegistered(@AncestorInPath Job<?, ?> job) {
             for (GitHubRepositoryName repo : repos) {
                 if (monitor.isProblemWith(repo)) {
                     return FormValidation.warning(
-                            github_trigger_check_method_warning_details(
+                            org.jenkinsci.plugins.github.Messages.github_trigger_check_method_warning_details(
                                     repo.getUserName(), repo.getRepositoryName(), repo.getHost()
                             ));
                 }