From 093f750aa1ea5234dbe4f85207740a841b6a8770 Mon Sep 17 00:00:00 2001
From: Marcel Paffrath <marcel.paffrath@rub.de>
Date: Mon, 23 May 2016 12:06:55 +0200
Subject: [PATCH] tried worker function

---
 pylot/core/active/seismicshot.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pylot/core/active/seismicshot.py b/pylot/core/active/seismicshot.py
index 3195af4a..63f1911c 100644
--- a/pylot/core/active/seismicshot.py
+++ b/pylot/core/active/seismicshot.py
@@ -327,6 +327,7 @@ class SeismicShot(object):
 
     def pickParallel(self, folm, method = 'hos', aicwindow = (10, 0)):
         import multiprocessing
+        from pylot.core.util.utils import worker
 
         self.setFolm(folm)
         self.setMethod(method)
@@ -337,11 +338,10 @@ class SeismicShot(object):
         
         traceIDs = self.getTraceIDlist()
 
-        picks = pool.map(self.pickTrace, traceIDs)
+        picks = worker(self.pickTrace, traceIDs, maxthreads)
 
         for traceID, pick in picks:
             self.setPick(traceID, pick)
-
         
     def pickTrace(self, traceID):
         '''