Adds an item to the work queue. Can be called dynamically while processing the results from imap_unordered.
(self, args)
| 305 | pass |
| 306 | |
| 307 | def add(self, args): |
| 308 | """Adds an item to the work queue. Can be called dynamically while |
| 309 | processing the results from imap_unordered.""" |
| 310 | assert not self.terminated |
| 311 | |
| 312 | self.work_queue.put(args) |
| 313 | self.processing_count += 1 |
| 314 | |
| 315 | def abort(self): |
| 316 | """Schedules abort on next queue read. |