Module Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore ListLoad Str ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr While NameLoad body For NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Num body Expr Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr ListComp Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr comprehension NameStore Call NameLoad AttributeLoad NameLoad attr Expr Call NameLoad AttributeLoad NameLoad attr For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body For NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Yield NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str decorator_list decorator_list
N/A N/A multiprocessing six.moves range base ProxyDataFlow utils.concurrency ensure_proc_terminate utils logger N/A __all__ N/A PrefetchData PrefetchProcess N/A N/A multiprocessing Process N/A __init__ N/A N/A self ds queue N/A N/A N/A 
        :param ds: ds to take data from
        :param queue: output queue to put results in
         N/A N/A N/A N/A super PrefetchProcess self __init__ N/A N/A self ds ds N/A N/A self queue queue N/A run N/A N/A self N/A N/A N/A N/A N/A N/A self ds reset_state N/A True N/A N/A dp N/A N/A N/A self ds get_data N/A N/A N/A N/A N/A self queue put dp N/A N/A PrefetchData N/A ProxyDataFlow N/A N/A 
    Prefetch data from a `DataFlow` using multiprocessing
     __init__ N/A N/A self ds nr_prefetch nr_proc N/A 1 N/A N/A 
        :param ds: a `DataFlow` instance.
        :param nr_prefetch: size of the queue to hold prefetched datapoints.
        :param nr_proc: number of processes to use. When larger than 1, order
            of data points will be random.
         N/A N/A N/A N/A super PrefetchData self __init__ ds N/A N/A self _size N/A N/A self size N/A N/A self nr_proc nr_proc N/A N/A self nr_prefetch nr_prefetch N/A N/A self queue N/A N/A multiprocessing Queue N/A self nr_prefetch N/A N/A self procs N/A N/A PrefetchProcess N/A self ds N/A self queue N/A _ N/A range N/A self nr_proc N/A N/A ensure_proc_terminate N/A self procs N/A x N/A self procs N/A N/A N/A N/A x start N/A get_data N/A N/A self N/A N/A N/A _ N/A range N/A self _size N/A N/A dp N/A N/A N/A self queue get N/A N/A dp N/A __del__ N/A N/A self N/A N/A N/A N/A N/A logger info Prefetch process exiting... N/A N/A N/A N/A self queue close N/A x N/A self procs N/A N/A N/A N/A x terminate N/A N/A N/A logger info Prefetch process exited. N/A N/A