queue_manager.py 文件源码

def __init__(self):

        self.df_to_tp = dict()

        self.attached_dataframes = set()

        self.tp_to_attached_df = dict()

        self.queues = dict()

        self.type_map = dict()

        self.add_lock = RLock()

    #################################################
    ### Static Methods ##############################
    #################################################



    #################################################
    ### API Methods #################################
    #################################################