Public Member Functions | |
def | __init__ |
def | add_thread |
def | run |
Public Attributes | |
index | |
num_threads | |
outputs | |
sequentializers | |
silent | |
threads |
def common.DistributedWork.__init__ | ( | self, | |
capacity, | |||
num_threads = 10 , |
|||
silent = True |
|||
) |
def common.DistributedWork.add_thread | ( | self, | |
worker | |||
) |
def common.DistributedWork.run | ( | self | ) |