Skip to content
This repository was archived by the owner on Mar 19, 2021. It is now read-only.

Commit 2316708

Browse files
authored
Merge pull request #332 from ariddell/feature/issue-249
Avoid using context manager with multiprocessing.Pool
2 parents c6ad85d + 634d937 commit 2316708

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

pystan/model.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,12 @@ def _map_parallel(function, args, n_jobs):
7676
if multiprocessing and int(n_jobs) not in (0, 1):
7777
if n_jobs == -1:
7878
n_jobs = None
79-
with multiprocessing.Pool(processes=n_jobs) as pool:
79+
try:
80+
pool = multiprocessing.Pool(processes=n_jobs)
8081
map_result = pool.map(function, args)
82+
finally:
83+
pool.close()
84+
pool.join()
8185
else:
8286
map_result = list(map(function, args))
8387
return map_result

0 commit comments

Comments
 (0)