cierro pool de threads

datosgobar · Oct 8, 2019 · f5c863f · f5c863f
1 parent 72cd384
commit f5c863f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pydatajson/threading_helper.py b/pydatajson/threading_helper.py
@@ -3,5 +3,7 @@
 
 def apply_threading(l, function, cant_threads):
     pool = ThreadPool(processes=cant_threads)
-
-    return pool.map(function, l)
+    results = pool.map(function, l)
+    pool.close()
+    pool.join()
+    return results