[commons-compress] branch master updated: Better internal name

[gg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-compress.git


The following commit(s) were added to refs/heads/master by this push:
     new f4677eab Better internal name
f4677eab is described below

commit f4677eab063c306263acb06b088258eaf447b896
Author: Gary Gregory <ga...@gmail.com>
AuthorDate: Mon Jan 23 07:06:01 2023 -0500

    Better internal name
---
 .../compress/archivers/zip/ParallelScatterZipCreator.java      | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/main/java/org/apache/commons/compress/archivers/zip/ParallelScatterZipCreator.java b/src/main/java/org/apache/commons/compress/archivers/zip/ParallelScatterZipCreator.java
index 2ade4aed..b46fb0bf 100644
--- a/src/main/java/org/apache/commons/compress/archivers/zip/ParallelScatterZipCreator.java
+++ b/src/main/java/org/apache/commons/compress/archivers/zip/ParallelScatterZipCreator.java
@@ -52,7 +52,7 @@ import org.apache.commons.compress.parallel.ScatterGatherBackingStoreSupplier;
 public class ParallelScatterZipCreator {
 
     private final Deque<ScatterZipOutputStream> streams = new ConcurrentLinkedDeque<>();
-    private final ExecutorService es;
+    private final ExecutorService executorService;
     private final ScatterGatherBackingStoreSupplier backingStoreSupplier;
 
     private final Deque<Future<? extends ScatterZipOutputStream>> futures = new ConcurrentLinkedDeque<>();
@@ -125,7 +125,7 @@ public class ParallelScatterZipCreator {
         }
 
         this.backingStoreSupplier = backingStoreSupplier;
-        es = executorService;
+        this.executorService = executorService;
         this.compressionLevel = compressionLevel;
     }
 
@@ -262,7 +262,7 @@ public class ParallelScatterZipCreator {
      * @since 1.19
      */
     public final void submitStreamAwareCallable(final Callable<? extends ScatterZipOutputStream> callable) {
-        futures.add(es.submit(callable));
+        futures.add(executorService.submit(callable));
     }
 
     /**
@@ -290,10 +290,10 @@ public class ParallelScatterZipCreator {
                     future.get();
                 }
             } finally {
-                es.shutdown();
+                executorService.shutdown();
             }
 
-            es.awaitTermination(1000 * 60L, TimeUnit.SECONDS);  // == Infinity. We really *must* wait for this to complete
+            executorService.awaitTermination(1000 * 60L, TimeUnit.SECONDS);  // == Infinity. We really *must* wait for this to complete
 
             // It is important that all threads terminate before we go on, ensure happens-before relationship
             compressionDoneAt = System.currentTimeMillis();