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

tried worker function

Browse Source
This commit is contained in:
Marcel Paffrath 2016-05-23 12:06:55 +02:00
parent 41b7ca6968
commit 093f750aa1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pylot/core/active/seismicshot.py
View File

@ -327,6 +327,7 @@ class SeismicShot(object):
def pickParallel(self, folm, method = 'hos', aicwindow = (10, 0)): def pickParallel(self, folm, method = 'hos', aicwindow = (10, 0)):
import multiprocessing import multiprocessing
from pylot.core.util.utils import worker
self.setFolm(folm) self.setFolm(folm)
self.setMethod(method) self.setMethod(method)
@ -337,11 +338,10 @@ class SeismicShot(object):
traceIDs = self.getTraceIDlist() traceIDs = self.getTraceIDlist()
picks = pool.map(self.pickTrace, traceIDs) picks = worker(self.pickTrace, traceIDs, maxthreads)
for traceID, pick in picks: for traceID, pick in picks:
self.setPick(traceID, pick) self.setPick(traceID, pick)
def pickTrace(self, traceID): def pickTrace(self, traceID):
''' '''