106 for task in argumentsList[:initialTasks]: |
106 for task in argumentsList[:initialTasks]: |
107 taskQueue.put(task) |
107 taskQueue.put(task) |
108 |
108 |
109 # Start worker processes |
109 # Start worker processes |
110 for _ in range(NumberOfProcesses): |
110 for _ in range(NumberOfProcesses): |
111 multiprocessing.Process(target=worker, args=(taskQueue, doneQueue))\ |
111 multiprocessing.Process( |
112 .start() |
112 target=worker, args=(taskQueue, doneQueue) |
|
113 ).start() |
113 |
114 |
114 # Get and send results |
115 # Get and send results |
115 endIndex = len(argumentsList) - initialTasks |
116 endIndex = len(argumentsList) - initialTasks |
116 for i in range(len(argumentsList)): |
117 for i in range(len(argumentsList)): |
117 resultSent = False |
118 resultSent = False |