This commit is contained in:
Marcel Paffrath 2016-05-31 11:15:30 +02:00
parent ae2fc73d89
commit 0520df5963

View File

@ -18,7 +18,6 @@ def _pickle_method(m):
def worker(func, input, cores='max', async=False): def worker(func, input, cores='max', async=False):
return result
import multiprocessing import multiprocessing
if cores == 'max': if cores == 'max':
@ -30,6 +29,7 @@ def worker(func, input, cores='max', async=False):
else: else:
result = pool.map(func, input) result = pool.map(func, input)
pool.close() pool.close()
return result
def demeanTrace(trace, window): def demeanTrace(trace, window):