mirror of
https://github.com/ParticulateFlow/LPP.git
synced 2025-12-08 06:37:46 +00:00
bugfixes:
- workaround for python issue 8296 (http://bugs.python.org/issue8296) - lpp can be interrupted pressing ctrl+c
This commit is contained in:
@ -105,10 +105,11 @@ class lpp:
|
|||||||
job_server = multiprocessing.Pool(processes = self.cpunum)
|
job_server = multiprocessing.Pool(processes = self.cpunum)
|
||||||
|
|
||||||
# map lppWorker on all inputs via job_server (parallelly)
|
# map lppWorker on all inputs via job_server (parallelly)
|
||||||
job_server.map(lppWorker,dumpInput[i:i+self.cpunum])
|
job_server.map_async(lppWorker,dumpInput[i:i+self.cpunum]).get(9999999)
|
||||||
|
|
||||||
# close jobserver
|
# close jobserver
|
||||||
job_server.close()
|
job_server.close()
|
||||||
|
job_server.join()
|
||||||
i += self.cpunum
|
i += self.cpunum
|
||||||
|
|
||||||
endtime = time.time()
|
endtime = time.time()
|
||||||
|
|||||||
Reference in New Issue
Block a user