(self)
| 200 | yield from super(MultiThreadMapData, self).__iter__() |
| 201 | |
| 202 | def __del__(self): |
| 203 | if self._evt is not None: |
| 204 | self._evt.set() |
| 205 | for p in self._threads: |
| 206 | p.stop() |
| 207 | p.join(timeout=5.0) |
| 208 | # if p.is_alive(): |
| 209 | # logger.warn("Cannot join thread {}.".format(p.name)) |
| 210 | |
| 211 | |
| 212 | class MultiProcessMapDataZMQ(_ParallelMapData, _MultiProcessZMQDataFlow): |