cutcutcodec.core.opti.parallel.buffer

Buffer management in threading loop.

Functions

imap(func, args[, maxsize])

Do same as multiprocessing.pool.ThreadPool.imap but with a limited output buffer.

starimap(func, args[, maxsize])

Like cutcutcodec.core.opti.parallel.imap with stared args.