224 taskQueue = multiprocessing.Queue() |
224 taskQueue = multiprocessing.Queue() |
225 doneQueue = multiprocessing.Queue() |
225 doneQueue = multiprocessing.Queue() |
226 |
226 |
227 # Submit tasks (initially two times the number of processes) |
227 # Submit tasks (initially two times the number of processes) |
228 tasks = len(argumentsList) |
228 tasks = len(argumentsList) |
229 initialTasks = 2 * NumberOfProcesses |
229 initialTasks = min(2 * NumberOfProcesses, tasks) |
230 for _ in range(initialTasks): |
230 for _ in range(initialTasks): |
231 taskQueue.put(argumentsList.pop(0)) |
231 taskQueue.put(argumentsList.pop(0)) |
232 |
232 |
233 # Start worker processes |
233 # Start worker processes |
234 workers = [ |
234 workers = [ |