Introduce ConcurrentExecutorHelper

src/main/groovy/com/eficode/atlassian/jiraInstanceManager/JiraInstanceManagerRest.groovy

@@ -11,6 +11,7 @@ import com.eficode.atlassian.jiraInstanceManager.beans.ProjectBean
 import com.eficode.atlassian.jiraInstanceManager.beans.ScriptFieldBean
 import com.eficode.atlassian.jiraInstanceManager.beans.SpockResult
 import com.eficode.atlassian.jiraInstanceManager.beans.SrJob
+import com.eficode.atlassian.jiraInstanceManager.concurrent.ConcurrentExecutorHelper
 import groovy.ant.AntBuilder
 import groovy.io.FileType
 import groovy.json.JsonSlurper
@@ -35,6 +36,7 @@ import unirest.shaded.org.apache.http.conn.HttpHostConnectException
 
 import java.nio.file.StandardCopyOption
 
+
 final class JiraInstanceManagerRest {
 
     static Logger log = LoggerFactory.getLogger(JiraInstanceManagerRest.class)
@@ -1679,19 +1681,16 @@ final class JiraInstanceManagerRest {
                     }
                 }
 
+                ConcurrentExecutorHelper.executeInParallel({ state ->
+                    directoryFiles.each { subFile ->
+                        String destinationPath = destFilePath + srcFile.relativePath(subFile)
 
-                directoryFiles.each { subFile ->
-
-                    String destinationPath = destFilePath + srcFile.relativePath(subFile)
-
-                    destinationPath = destinationPath.startsWith("/") ? destinationPath.substring(1) : destinationPath
-
-                    log.info("\tUpdating:" + subFile.name + ", Destination: " + destinationPath)
-                    assert updateScriptrunnerFile(subFile.text, destinationPath), "Error updating " + subFile.name
-
-                }
-
+                        destinationPath = destinationPath.startsWith("/") ? destinationPath.substring(1) : destinationPath
 
+                        log.info("\tUpdating:" + subFile.name + ", Destination: " + destinationPath)
+                        state({-> assert updateScriptrunnerFile(subFile.text, destinationPath), "Error updating " + subFile.name})
+                    }
+                })
             } else {
                 log.info("\tUpdating:" + srcFile.name)
                 assert updateScriptrunnerFile(srcFile.text, destFilePath), "Error updating " + srcFile.name

src/main/groovy/com/eficode/atlassian/jiraInstanceManager/concurrent/ConcurrentExecutorHelper.groovy

@@ -0,0 +1,27 @@
+package com.eficode.atlassian.jiraInstanceManager.concurrent
+
+import java.util.concurrent.*
+
+public class ConcurrentExecutorHelper {
+
+    public static <T> List<T> executeInParallel(Closure<List<T>> closure) {
+        ExecutorService pool = Executors.newFixedThreadPool(10)
+        ExecutorCompletionService<T> ecs =  new ExecutorCompletionService<T>(pool)
+
+        List<Future<T>> futures = []
+        List<T> results = []
+        try {
+            closure.call({ task ->
+                futures << ecs.submit(task)
+            })
+            futures.each { future ->
+                results << future.get()
+            }
+        } finally {
+            pool.shutdown()
+        }
+        return results
+    }
+
+
+}