Working example... Debugging.
| | |
| | | class PostProcess(multiprocessing.Process): |
| | | |
| | | def __init__(self, dirlist): |
| | | super(PostProcess, self).__init_ |
| | | super(PostProcess, self).__init__() |
| | | self.dirlist=dirlist |
| | | def run(self): |
| | | for d in self.dirlist: |
| | |
| | | django.setup() |
| | | from database import models |
| | | objs=models.Run.objects.order_by('id').all() |
| | | dirlist=[[]] |
| | | dirlist=[[],[],[]] |
| | | for i,obj in enumerate(objs): |
| | | cdir=os.path.join(obj.simulation.directory, obj.subdir) |
| | | dirlist[i%NUM_PROCESSES].append(cdir) |
| | | print(dirlist) |
| | | pp=[] |
| | | for i,d in enumerate(dirlist): |
| | | j=Postprocess(d) |
| | | j=PostProcess(d) |
| | | pp.append(j) |
| | | j.start() |
| | | for i in pp: |
| | | pp.join() |
| | | i.join() |