marcel/pylot
3
0
Fork 0
Code Issues 7 Pull Requests 1 Releases Wiki Activity

[fix] fixing a bug introduced accidently by merge

Browse Source
This commit is contained in:
Sebastian Wehling-Benatelli 2016-05-27 06:49:20 +02:00
parent 0dd69a0e19
commit 53614bb5b9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pylot/core/util/utils.py
View File

@ -18,19 +18,19 @@ 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':
cores = multiprocessing.cpu_count() cores = multiprocessing.cpu_count()
pool = multiprocessing.Pool(cores)
pool = multiprocessing.Pool(cores)
if async == True: if async == True:
result = pool.map_async(func, input) result = pool.map_async(func, input)
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):
""" """