200 taskQueue.put('STOP') |
199 taskQueue.put('STOP') |
201 |
200 |
202 |
201 |
203 def worker(inputQueue, outputQueue): |
202 def worker(inputQueue, outputQueue): |
204 """ |
203 """ |
205 Module function acting as the parallel worker for the style check. |
204 Module function acting as the parallel worker for the syntax check. |
206 |
205 |
207 @param inputQueue input queue (multiprocessing.Queue) |
206 @param inputQueue input queue (multiprocessing.Queue) |
208 @param outputQueue output queue (multiprocessing.Queue) |
207 @param outputQueue output queue (multiprocessing.Queue) |
209 """ |
208 """ |
210 for filename, args in iter(inputQueue.get, 'STOP'): |
209 for filename, args in iter(inputQueue.get, 'STOP'): |