[LLM] ⚡ Bolt: Parallelize dependency resolution and target generation

.jules/bolt.md

@@ -0,0 +1 @@
+# Bolt's Journal

resolver/src/main/java/net/evendanan/bazel/mvn/Merger.java

@@ -340,7 +340,7 @@ private void writeResults(
             "Constructing Bazel targets",
             "%d out of %d (%.2f%%%s): %s...");
     List<TargetsToWrite> targetsToWritePairs =
-        resolvedDependencies.stream()
+        resolvedDependencies.parallelStream()
             .peek(d -> timer.taskDone(dependencyTools.mavenCoordinates(d)))
             .map(
                 dependency ->

resolver/src/main/java/net/evendanan/bazel/mvn/impl/TargetsBuilders.java

@@ -180,12 +180,10 @@ private static Target addAlias(
   public static class HttpTargetsBuilder implements TargetsBuilder {
     private static final char[] hexArray = "0123456789abcdef".toCharArray();
     private final boolean calculateSha;
-    private final byte[] readBuffer;
     private final Function<Dependency, URI> downloader;
 
     public HttpTargetsBuilder(boolean calculateSha, Function<Dependency, URI> downloader) {
       this.calculateSha = calculateSha;
-      this.readBuffer = calculateSha ? new byte[4096] : new byte[0];
       this.downloader = downloader;
     }
 
@@ -205,6 +203,7 @@ public List<Target> buildTargets(final Dependency dependency, DependencyTools de
       if (calculateSha && !dependency.mavenCoordinate().version().contains("SNAPSHOT")) {
         try (InputStream inputStream = downloader.apply(dependency).toURL().openStream()) {
           final MessageDigest digest = MessageDigest.getInstance("SHA-256");
+          final byte[] readBuffer = new byte[16384];
 
           int bytesCount;
           while ((bytesCount = inputStream.read(readBuffer)) != -1) {

resolver/src/main/java/net/evendanan/timing/ProgressTimer.java

@@ -13,7 +13,7 @@ public ProgressTimer(int tasksCount, String title, String progressText) {
     this.timer.start(tasksCount);
   }
 
-  public void taskDone(String taskName) {
+  public synchronized void taskDone(String taskName) {
     final TimingData timingData = timer.taskDone();
     final String estimatedTimeLeft;
     if (timingData.doneTasks >= 3) {
@@ -32,7 +32,7 @@ public void taskDone(String taskName) {
         taskName);
   }
 
-  public void finish() {
+  public synchronized void finish() {
     TimingData finish = timer.finish();
     report("Finished. %s", TaskTiming.humanReadableTime(finish.totalTime - finish.startTime));
   }

resolver/src/main/java/net/evendanan/timing/TaskTiming.java

@@ -25,32 +25,33 @@ public static String humanReadableTime(long milliseconds) {
     return timeString;
   }
 
-  public TimingData start(final int totalTasksCount) {
+  public synchronized TimingData start(final int totalTasksCount) {
     startTime = getCurrentTime();
     completedTasks = 0;
     totalTasks = totalTasksCount;
     return generateTimingData();
   }
 
-  public TimingData updateTotalTasks(final int totalTasksCount) {
+  public synchronized TimingData updateTotalTasks(final int totalTasksCount) {
     totalTasks = totalTasksCount;
     return generateTimingData();
   }
 
-  public TimingData taskDone() {
+  public synchronized TimingData taskDone() {
     completedTasks++;
     return generateTimingData();
   }
 
-  public TimingData finish() {
+  public synchronized TimingData finish() {
     return generateTimingData();
   }
 
   private TimingData generateTimingData() {
     final long totalTime = getCurrentTime();
     final long duration = totalTime - startTime;
     final float ratioOfDone = completedTasks / (float) totalTasks;
-    final long estimatedTimeLeft = (long) (duration / ratioOfDone) - duration;
+    final long estimatedTimeLeft =
+        (ratioOfDone == 0) ? 0 : (long) (duration / ratioOfDone) - duration;
 
     return new TimingData(
         totalTasks, completedTasks, startTime, totalTime, estimatedTimeLeft, ratioOfDone);