'Initialize the DataSourceThread instance.
Args:
request_manager: A RequestManager instance.
kinds: The kinds of entities being transferred.
thread_pool: An AdaptiveThreadPool instance.
progress_queue: A queue used for tracking progress information.
workitem_generator_factory: A factory that creates a WorkItem generator
progress_generator_factory: A factory that creates a generator which
produces prior progress status, or None if there is no prior status
to use.'

def __init__(self, request_manager, kinds, thread_pool, progress_queue, workitem_generator_factory, progress_generator_factory):

    _ThreadBase.__init__(self)
    self.request_manager = request_manager
    self.kinds = kinds
    self.thread_pool = thread_pool
    self.progress_queue = progress_queue
    self.workitem_generator_factory = workitem_generator_factory
    self.progress_generator_factory = progress_generator_factory
    self.entity_count = 0
