polishing
This commit is contained in:
parent
dc9bfd1849
commit
be45d62f53
|
@ -949,9 +949,7 @@ class DADF5():
|
||||||
|
|
||||||
|
|
||||||
def _job(self,group,func,datasets,args,lock):
|
def _job(self,group,func,datasets,args,lock):
|
||||||
"""
|
"""Execute job for _add_generic_pointwise."""
|
||||||
Execute job for _add_generic_pointwise
|
|
||||||
"""
|
|
||||||
try:
|
try:
|
||||||
datasets_in = {}
|
datasets_in = {}
|
||||||
lock.acquire()
|
lock.acquire()
|
||||||
|
@ -981,6 +979,7 @@ class DADF5():
|
||||||
Details of the datasets to be used: label (in HDF5 file) and arg (argument to which the data is parsed in func).
|
Details of the datasets to be used: label (in HDF5 file) and arg (argument to which the data is parsed in func).
|
||||||
args : dictionary, optional
|
args : dictionary, optional
|
||||||
Arguments parsed to func.
|
Arguments parsed to func.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
N_threads = int(Environment().options['DAMASK_NUM_THREADS'])
|
N_threads = int(Environment().options['DAMASK_NUM_THREADS'])
|
||||||
pool = multiprocessing.Pool(N_threads)
|
pool = multiprocessing.Pool(N_threads)
|
||||||
|
|
Loading…
Reference in New Issue