95 taskQueue = multiprocessing.Queue() |
95 taskQueue = multiprocessing.Queue() |
96 doneQueue = multiprocessing.Queue() |
96 doneQueue = multiprocessing.Queue() |
97 |
97 |
98 # Submit tasks (initially two times the number of processes) |
98 # Submit tasks (initially two times the number of processes) |
99 tasks = len(argumentsList) |
99 tasks = len(argumentsList) |
100 initialTasks = 2 * NumberOfProcesses |
100 initialTasks = min(2 * NumberOfProcesses, tasks) |
101 for _ in range(initialTasks): |
101 for _ in range(initialTasks): |
102 taskQueue.put(argumentsList.pop(0)) |
102 taskQueue.put(argumentsList.pop(0)) |
103 |
103 |
104 # Start worker processes |
104 # Start worker processes |
105 workers = [ |
105 workers = [ |