weblib.work

weblib.work.make_work(callback, tasks, limit, ignore_exceptions=True, taskq_size=50)[source]

Run up to “limit” threads, do tasks and yield results.

Parameters:
  • callback – the function that will process single task
  • tasks – the sequence or iterator or queue of tasks, each task in turn is sequence of arguments, if task is just signle argument it should be wrapped into list or tuple
  • limit – the maximum number of threads