9283:0e9d2c4e379e | 9284:3b3a4f659782 |
---|---|
188 taskQueue.put("STOP") | 188 taskQueue.put("STOP") |
189 | 189 |
190 for worker in workers: | 190 for worker in workers: |
191 worker.join() | 191 worker.join() |
192 worker.close() | 192 worker.close() |
193 | 193 |
194 taskQueue.close() | 194 taskQueue.close() |
195 doneQueue.close() | 195 doneQueue.close() |
196 | 196 |
197 | 197 |
198 def workerTask(inputQueue, outputQueue): | 198 def workerTask(inputQueue, outputQueue): |