(self, generator, num_prefetch_queue)
| 16 | """ |
| 17 | |
| 18 | def __init__(self, generator, num_prefetch_queue): |
| 19 | threading.Thread.__init__(self) |
| 20 | self.queue = Queue.Queue(num_prefetch_queue) |
| 21 | self.generator = generator |
| 22 | self.daemon = True |
| 23 | self.start() |
| 24 | |
| 25 | def run(self): |
| 26 | for item in self.generator: |