(self, data)
| 131 | self.result = sum(pool.done) |
| 132 | |
| 133 | def map_gen(self, data): |
| 134 | pool = fastthreadpool.Pool() |
| 135 | pool.map(self.worker_gen, data) |
| 136 | pool.shutdown() |
| 137 | self.result = sum(pool.done) |
| 138 | |
| 139 | def map_gen_done_cb(self, data): |
| 140 | with fastthreadpool.Pool(done_callback=self.result_cb) as pool: |