|
@@ -42,7 +42,7 @@ def pmap(func, iterable, processes, should_print_progress, *args, **kwargs):
|
|
|
|
|
|
func_and_args = [(func, arg, should_print_progress,) for arg in iterable]
|
|
func_and_args = [(func, arg, should_print_progress,) for arg in iterable]
|
|
if processes == 1:
|
|
if processes == 1:
|
|
- result = map(_wrapped_func, func_and_args, *args, **kwargs)
|
|
|
|
|
|
+ result = list(map(_wrapped_func, func_and_args, *args, **kwargs))
|
|
else:
|
|
else:
|
|
pool = multiprocessing.Pool(initializer=_init,
|
|
pool = multiprocessing.Pool(initializer=_init,
|
|
initargs=(_current, _total,),
|
|
initargs=(_current, _total,),
|