parallelizer()

google · Nov 30, 2024 · 04693bb · 04693bb
1 parent d80fb13
commit 04693bb
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java b/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java
@@ -448,11 +448,15 @@ Scope add(Runnable... tasks) {
     }
 
     void run() throws InterruptedException {
-      new Parallelizer(executor, runnables.size()).parallelize(runnables.stream());
+      parallelizer().parallelize(runnables.stream());
     }
 
     void runUninterruptibly() {
-      new Parallelizer(executor, runnables.size()).parallelizeUninterruptibly(runnables.stream());
+      parallelizer().parallelizeUninterruptibly(runnables.stream());
+    }
+
+    private Parallelizer parallelizer() {
+      return new Parallelizer(executor, runnables.size());
     }
   }