Changeset 496 for MPbranch/GSASIIstruct.py

Timestamp:

Feb 24, 2012 3:12:00 PM (10 years ago)

Author:

vondreele

Message:

making 1st multiprocess version of GSAS-II

Location:

MPbranch

Files:

• . (copied) (copied from trunk)
• GSASIIstruct.py (copied) (copied from trunk/GSASIIstruct.py) (2 diffs)

MPbranch/GSASIIstruct.py

@@ -2675 +2675 @@
     if MaxProcess > 1: 
         mpPool = mp.Pool(processes=MaxProcess)
-        results = mpPool.map(ComputePowderHessian,argList)
-        for Vec,Hess in results:
+        #results = mpPool.map(ComputePowderHessian,argList)
+        #for Vec,Hess in results:
+        for Vec,Hess in mpPool.imap_unordered(ComputePowderHessian,argList):
             VecSum += Vec
             HessSum += Hess
@@ -2765 +2766 @@
     if MaxProcess > 1: 
         mpPool = mp.Pool(processes=MaxProcess)
-        results = mpPool.map(ComputePowderProfile,argList)
-        for arg,res in zip(argList,results):
+        #results = mpPool.map(ComputePowderProfile,argList)
+        #for arg,res in zip(argList,results):
+        #results = mpPool.map(ComputePowderProfile,argList)
+        #for i,res in enumerate(results):
+        for i,res in enumerate(
+            mpPool.imap_unordered(ComputePowderProfile,argList)
+            ):
+            print 'process',i
             xB,xF,ycSect,ybSect,RL = res
-            Histogram = arg[0]
+            Histogram = argList[i][0]
             Histogram['Reflection Lists'] = RL
             x,y,w,yc,yb,yd = Histogram['Data']