176 # Tell child processes to stop |
176 # Tell child processes to stop |
177 for i in range(NumberOfProcesses): |
177 for i in range(NumberOfProcesses): |
178 taskQueue.put('STOP') |
178 taskQueue.put('STOP') |
179 |
179 |
180 |
180 |
181 def worker(input, output): |
181 def worker(inputQueue, outputQueue): |
182 """ |
182 """ |
183 Module function acting as the parallel worker for the style check. |
183 Module function acting as the parallel worker for the style check. |
184 |
184 |
185 @param input input queue (multiprocessing.Queue) |
185 @param inputQueue input queue (multiprocessing.Queue) |
186 @param output output queue (multiprocessing.Queue) |
186 @param outputQueue output queue (multiprocessing.Queue) |
187 """ |
187 """ |
188 for filename, source in iter(input.get, 'STOP'): |
188 for filename, source in iter(inputQueue.get, 'STOP'): |
189 result = __check(filename, source) |
189 result = __check(filename, source) |
190 output.put((filename, result)) |
190 outputQueue.put((filename, result)) |
191 |
191 |
192 |
192 |
193 def __check(file, text=""): |
193 def __check(file, text=""): |
194 """ |
194 """ |
195 Private function to check one Python source file for whitespace related |
195 Private function to check one Python source file for whitespace related |