Merge pull request #29 from asarkar/issue-27

issue-27: Support parallel builds

Author: asarkar

gradle.properties

@@ -11,7 +11,7 @@ pluginImplementationClass = com.asarkar.gradle.buildtimetracker.BuildTimeTracker
 pluginDeclarationName = buildTimeTrackerPlugin
 
 projectGroup = com.asarkar.gradle
-projectVersion = 3.0.0
+projectVersion = 3.0.1
 
 junitVersion = latest.release
 assertjVersion = latest.release

src/main/kotlin/com/asarkar/gradle/buildtimetracker/Printer.kt

@@ -13,7 +13,7 @@ import kotlin.math.round
 
 data class PrinterInput(
     val buildDuration: Long,
-    val taskDurations: List<Pair<String, Long>>,
+    val taskDurations: Collection<Pair<String, Long>>,
     val maxWidth: Int,
     val showBars: Boolean,
     val barPosition: BarPosition

src/main/kotlin/com/asarkar/gradle/buildtimetracker/TimingRecorder.kt

@@ -11,18 +11,21 @@ import org.gradle.api.reflect.TypeOf
 import org.gradle.api.tasks.TaskState
 import java.time.Duration
 import java.time.Instant
+import java.util.concurrent.ConcurrentHashMap
+import java.util.concurrent.ConcurrentLinkedQueue
 
 class TimingRecorder(private val ext: BuildTimeTrackerPluginExtension) : TaskExecutionListener, BuildAdapter() {
-    private lateinit var taskStarted: Instant
+    private val taskStartTimings: MutableMap<String, Instant> = ConcurrentHashMap()
+    private val taskDurations: MutableCollection<Pair<String, Long>> = ConcurrentLinkedQueue()
     private lateinit var buildStarted: Instant
-    private val taskDurations = mutableListOf<Pair<String, Long>>()
 
     override fun beforeExecute(task: Task) {
-        taskStarted = Instant.now()
+        taskStartTimings[task.path] = Instant.now()
     }
 
     override fun afterExecute(task: Task, state: TaskState) {
-        val duration = Duration.between(taskStarted, Instant.now()).seconds
+        check(taskStartTimings.contains(task.path)) { "No start timing for task ${task.path}" }
+        val duration = Duration.between(taskStartTimings[task.path], Instant.now()).seconds
         if (duration >= ext.minTaskDuration.get().seconds) {
             taskDurations.add(task.path to duration)
         }
@@ -40,19 +43,16 @@ class TimingRecorder(private val ext: BuildTimeTrackerPluginExtension) : TaskExe
             return
         }
         val buildDuration = Duration.between(buildStarted, Instant.now()).seconds
-        if (ext.sort.get()) {
-            taskDurations.sortBy { -it.second }
-        }
         Printer.newInstance(ext)
-            .use {
+            .use { printer ->
                 val input = PrinterInput(
                     buildDuration,
-                    taskDurations,
+                    if (ext.sort.get()) taskDurations.sortedBy { -it.second } else taskDurations,
                     ext.maxWidth.get(),
                     ext.showBars.get(),
                     ext.barPosition.get()
                 )
-                it.print(input)
+                printer.print(input)
             }
     }