(self, pool)
| 837 | class IMapIterator(object): |
| 838 | |
| 839 | def __init__(self, pool): |
| 840 | self._pool = pool |
| 841 | self._cond = threading.Condition(threading.Lock()) |
| 842 | self._job = next(job_counter) |
| 843 | self._cache = pool._cache |
| 844 | self._items = collections.deque() |
| 845 | self._index = 0 |
| 846 | self._length = None |
| 847 | self._unsorted = {} |
| 848 | self._cache[self._job] = self |
| 849 | |
| 850 | def __iter__(self): |
| 851 | return self |