Method _guarded_task_generation

Lib/multiprocessing/pool.py:385–394

Provides a generator of tasks for imap and imap_unordered with appropriate handling for iterables which throw exceptions during iteration.

(self, result_job, func, iterable)

                               callback, error_callback)

    def _guarded_task_generation(self, result_job, func, iterable):
        '''Provides a generator of tasks for imap and imap_unordered with
        appropriate handling for iterables which throw exceptions during
        iteration.'''
        try:
            i = -1
            for i, x in enumerate(iterable):
                yield (result_job, i, func, (x,), {})
        except Exception as e:
            yield (result_job, i+1, _helper_reraises_exception, (e,), {})

    def imap(self, func, iterable, chunksize=1):
        '''