Wait for worker processes and validator threads
(self)
| 141 | logger.info('validator_thread started') |
| 142 | |
| 143 | def join(self): |
| 144 | """ |
| 145 | Wait for worker processes and validator threads |
| 146 | |
| 147 | """ |
| 148 | while (self.worker_process and self.worker_process.is_alive()) or ( |
| 149 | self.validator_thread and self.validator_thread.is_alive()): |
| 150 | try: |
| 151 | self.worker_process.join() |
| 152 | self.validator_thread.join() |
| 153 | except (KeyboardInterrupt, SystemExit): |
| 154 | break |
| 155 | |
| 156 | def feed_providers(self): |
| 157 | logger.debug('feed {} providers...'.format(len(all_providers))) |