9283:0e9d2c4e379e | 9284:3b3a4f659782 |
---|---|
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 | 272 |
273 taskQueue.close() | 273 taskQueue.close() |
274 doneQueue.close() | 274 doneQueue.close() |
275 | 275 |
276 | 276 |
277 def workerTask(inputQueue, outputQueue): | 277 def workerTask(inputQueue, outputQueue): |