9278:36448ca469c2 | 9279:e252f827aaa7 |
---|---|
267 taskQueue.put("STOP") | 267 taskQueue.put("STOP") |
268 | 268 |
269 for worker in workers: | 269 for worker in workers: |
270 worker.join() | 270 worker.join() |
271 worker.close() | 271 worker.close() |
272 | |
273 taskQueue.close() | |
274 doneQueue.close() | |
272 | 275 |
273 | 276 |
274 def workerTask(inputQueue, outputQueue): | 277 def workerTask(inputQueue, outputQueue): |
275 """ | 278 """ |
276 Module function acting as the parallel worker for the style check. | 279 Module function acting as the parallel worker for the style check. |