diff options
| author | Volker Hoffmann <volker@cheleb.net> | 2015-11-06 10:31:28 +0100 |
|---|---|---|
| committer | Volker Hoffmann <volker@cheleb.net> | 2015-11-06 10:31:28 +0100 |
| commit | 2820f85ed96e847e27685760ef63eb8788863228 (patch) | |
| tree | 9141f5db669dfd8e921b6b8822bb1bb7b319b3ad | |
| parent | 893865c66fb14c33a92475b8b91c70a888576272 (diff) | |
perf: use parallel chunksize of 1; otherwise one process gets stuck with all the intensive (early) outputs, and other only with easy (late) outputs -- probably adds a little of overhead, but meh
| -rw-r--r-- | Post/Formation/extract_wmf.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/Post/Formation/extract_wmf.py b/Post/Formation/extract_wmf.py index d4b9c85..8500530 100644 --- a/Post/Formation/extract_wmf.py +++ b/Post/Formation/extract_wmf.py @@ -75,7 +75,7 @@ for istep, nstep in enumerate(nsteps): # Loop Steps print "// Computing WMF & Sources for %i Steps" % len(targets) pool = mp.Pool(processes=args.np) -result = pool.map(fh.compute_wmf_wrapper, targets) +result = pool.map(fh.compute_wmf_wrapper, targets, 1) pool.close() pool.join() |