Lines Matching refs:result
90 return "Error sending result: '%s'. Reason: '%s'" % (self.value,
125 result = (True, func(*args, **kwds))
129 result = (False, e)
131 put((job, i, result))
133 wrapped = MaybeEncodingError(e, result[1])
134 util.debug("Possible encoding error while sending result: %s" % (
138 task = job = result = func = args = kwds = None
402 result = IMapIterator(self)
405 self._guarded_task_generation(result._job, func, iterable),
406 result._set_length
408 return result
415 result = IMapIterator(self)
418 self._guarded_task_generation(result._job,
421 result._set_length
423 return (item for chunk in result for item in chunk)
431 result = IMapUnorderedIterator(self)
434 self._guarded_task_generation(result._job, func, iterable),
435 result._set_length
437 return result
443 result = IMapUnorderedIterator(self)
446 self._guarded_task_generation(result._job,
449 result._set_length
451 return (item for chunk in result for item in chunk)
459 result = ApplyResult(self, callback, error_callback)
460 self._taskqueue.put(([(result._job, 0, func, args, kwds)], None))
461 return result
488 result = MapResult(self, chunksize, len(iterable), callback,
492 self._guarded_task_generation(result._job,
498 return result
560 # tell result handler to finish when cache is empty
561 util.debug('task handler sending sentinel to result handler')
581 util.debug('result handler got EOFError/OSError -- exiting')
586 util.debug('result handler found thread._state=TERMINATE')
590 util.debug('result handler got sentinel')
604 util.debug('result handler got EOFError/OSError -- exiting')
608 util.debug('result handler ignoring extra sentinel')
630 util.debug('result handler exiting: len(cache)=%s, thread._state=%s',
722 util.debug('joining result handler')
811 success, result = success_result
813 self._value[i*self._chunksize:(i+1)*self._chunksize] = result
824 self._value = result
826 # only consider the result ready once all jobs are done