terminate instead of close to prevent hanging pool.join. Fixes #1

Author: MatthewThe

job_pool/job_pool.py

@@ -59,7 +59,6 @@ class AbnormalWorkerTerminationError(Exception):
 
 
 class JobPool:
-    @threadpool_limits.wrap(limits=1, user_api='blas')
     def __init__(
         self,
         processes: int = 1,
@@ -121,8 +120,7 @@ def checkPool(self, printProgressEvery: int = -1):
             ):
                 self.checkForTerminatedProcess(res)
                 outputs.append(res.get())
-            self.pool.close()
-            self.pool.join()
+            self.stopPool()
             return outputs
         except (KeyboardInterrupt, SystemExit) as e:
             logger.error(f"Caught {e.__class__.__name__}, terminating workers")