| 794 | class MapResult(ApplyResult): |
| 795 | |
| 796 | def __init__(self, pool, chunksize, length, callback, error_callback): |
| 797 | ApplyResult.__init__(self, pool, callback, |
| 798 | error_callback=error_callback) |
| 799 | self._success = True |
| 800 | self._value = [None] * length |
| 801 | self._chunksize = chunksize |
| 802 | if chunksize <= 0: |
| 803 | self._number_left = 0 |
| 804 | self._event.set() |
| 805 | del self._cache[self._job] |
| 806 | else: |
| 807 | self._number_left = length//chunksize + bool(length % chunksize) |
| 808 | |
| 809 | def _set(self, i, success_result): |
| 810 | self._number_left -= 1 |