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)