close all workers when process is done

src/Compression/bloscZarrDecompress.js

@@ -4,6 +4,7 @@ import { getSize } from '../IO/dtypeUtils'
 const cores = navigator.hardwareConcurrency ? navigator.hardwareConcurrency : 4
 const numberOfWorkers = cores + Math.floor(Math.sqrt(cores))
 const workerPool = new WorkerPool(numberOfWorkers, runPipeline)
+workerPool.terminateWorkers()
 
 /**
  * Input:
@@ -53,7 +54,7 @@ async function bloscZarrDecompress(chunkData) {
     taskArgsArray.push(['BloscZarr', args, desiredOutputs, inputs])
   }
   const results = await workerPool.runTasks(taskArgsArray).promise
-
+  workerPool.terminateWorkers()
   const decompressedChunks = []
   for (let index = 0; index < results.length; index++) {
     // console.log(results[index].stdout)

src/IO/Analyze/computeHistograms.js

@@ -11,7 +11,7 @@ const updateHistogramWorkerPool = webWorkerPromiseWorkerPool(
   UpdateHistogramWorker,
   'updateHistogram'
 )
-
+updateHistogramWorkerPool.terminateWorkers()
 export const computeHistogram = async (
   values,
   component,
@@ -83,5 +83,6 @@ export const computeHistogram = async (
   for (let ii = 0; ii < numberOfBins; ii++) {
     histogram[ii] /= maxHistogram
   }
+  updateHistogramWorkerPool.terminateWorkers()
   return histogram
 }

src/IO/Analyze/computeRanges.js

@@ -12,7 +12,7 @@ const computeRangeWorkerPool = webWorkerPromiseWorkerPool(
   ComputeRangesWorker,
   'computeRanges'
 )
-
+computeRangeWorkerPool.terminateWorkers()
 export async function computeRanges(values, numberOfComponents = 1) {
   const numberOfSplits = numberOfWorkers
 
@@ -58,6 +58,6 @@ export async function computeRanges(values, numberOfComponents = 1) {
       helpers[compIdx].add(max)
     })
   })
-
+  computeRangeWorkerPool.terminateWorkers()
   return helpers.map(h => h.getRange())
 }

src/IO/InMemoryMultiscaleSpatialImage.js

@@ -15,6 +15,7 @@ const numberOfWorkers = navigator.hardwareConcurrency
   ? navigator.hardwareConcurrency
   : 6
 const downsampleWorkerPool = new WorkerPool(numberOfWorkers, runPipeline)
+downsampleWorkerPool.terminateWorkers()
 
 class Coords {
   constructor(image, dims) {
@@ -269,6 +270,7 @@ class InMemoryMultiscaleSpatialImage extends MultiscaleSpatialImage {
       }
       const results = await downsampleWorkerPool.runTasks(downsampleTaskArgs)
         .promise
+      downsampleWorkerPool.terminateWorkers()
       const validResults = results.filter(r => r.returnValue === 0)
       const imageSplits = validResults.map(({ outputs }) => outputs[0].data)
       currentImage = stackImages(imageSplits)

src/IO/MultiscaleSpatialImage.js

@@ -13,7 +13,7 @@ const imageDataFromChunksWorker = new ImageDataFromChunksWorker()
 const imageDataFromChunksWorkerPromise = new WebworkerPromise(
   imageDataFromChunksWorker
 )
-
+imageDataFromChunksWorkerPromise.terminate()
 /* Every element corresponds to a pyramid scale
      Lower scales, corresponds to a higher index, correspond to a lower
      resolution. 
@@ -341,7 +341,7 @@ class MultiscaleSpatialImage {
       'imageDataFromChunks',
       args
     )
-
+    imageDataFromChunksWorkerPromise.terminate()
     return {
       imageType: this.imageType,
       name: this.scaleInfo[scale].name,