Reset tile queue size if max workers is changed

glencoesoftware · Oct 16, 2023 · a0dafc7 · a0dafc7
1 parent 2cc870e
commit a0dafc7
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/com/glencoesoftware/pyramid/PyramidFromDirectoryWriter.java b/src/main/java/com/glencoesoftware/pyramid/PyramidFromDirectoryWriter.java
@@ -317,8 +317,9 @@ public void setSplitTIFFs(boolean split) {
       description = "Maximum number of workers (default: ${DEFAULT-VALUE})"
   )
   public void setMaxWorkers(int workers) {
-    if (workers > 0) {
+    if (workers > 0 && workers != maxWorkers) {
       maxWorkers = workers;
+      tileQueue = new LimitedQueue<Runnable>(maxWorkers);
     }
   }
 
@@ -495,7 +496,11 @@ public void resetSplitTIFFs() {
   /**
    */
   public void resetMaxWorkers() {
-    maxWorkers = Runtime.getRuntime().availableProcessors();
+    int defaultWorkers = Runtime.getRuntime().availableProcessors();
+    if (defaultWorkers != maxWorkers) {
+      maxWorkers = defaultWorkers;
+      tileQueue = new LimitedQueue<Runnable>(maxWorkers);
+    }
   }
 
   /**