170 for task in argumentsList[:initialTasks]: |
170 for task in argumentsList[:initialTasks]: |
171 taskQueue.put(task) |
171 taskQueue.put(task) |
172 |
172 |
173 # Start worker processes |
173 # Start worker processes |
174 for _ in range(NumberOfProcesses): |
174 for _ in range(NumberOfProcesses): |
175 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
175 multiprocessing.Process( |
176 .start() |
176 target=worker, args=(taskQueue, doneQueue) |
|
177 ).start() |
177 |
178 |
178 # Get and send results |
179 # Get and send results |
179 endIndex = len(argumentsList) - initialTasks |
180 endIndex = len(argumentsList) - initialTasks |
180 for i in range(len(argumentsList)): |
181 for i in range(len(argumentsList)): |
181 resultSent = False |
182 resultSent = False |