multiprocessing.pool.Pool.imap()

imap(func, iterable[, chunksize])

A lazier version of map().

The chunksize argument is the same as the one used by the map() method. For very long iterables using a large value for chunksize can make the job complete much faster than using the default value of 1.

Also if chunksize is 1 then the next() method of the iterator returned by the imap() method has an optional timeout parameter: next(timeout) will raise multiprocessing.TimeoutError if the result cannot be returned within timeout seconds.

Links:

https://docs.python.org/3.5/library/multiprocessing.html#multiprocessing.pool.Pool.imap

doc_python

2016-10-07 17:37:53

Comments

Popular Articles

multiprocessing.pool.Pool.imap_unordered() imap_unordered(func, iterable[, chunksize]) The same as imap() except that the ordering of the results from the returned iterator should be consid

multiprocessing.pool.Pool class multiprocessing.pool.Pool([processes[, initializer[, initargs[, maxtasksperchild[, context]]]]]) A process pool object which controls a pool

multiprocessing.pool.Pool.close() close() Prevents any more tasks from being submitted to the pool. Once all the tasks have been completed the worker processes will exit.

multiprocessing.pool.Pool.join() join() Wait for the worker processes to exit. One must call close() or terminate() before using join().

multiprocessing.pool.Pool.terminate() terminate() Stops the worker processes immediately without completing outstanding work. When the pool object is garbage collected terminate() will