inet.common.task.TaskProgress¶

class inet.common.task.TaskProgress(num_tasks, num_finished=0, scheduler='thread', *, manager=None, _shared_value=None, _shared_lock=None)¶

scheduler:

• “thread”: local int + threading.Lock

• “process”: multiprocessing.Manager() proxies (pickleable, safe to pass to workers)