def __init__(self, config):
        super(BufferThread, self).__init__()
        self.config = config
        self._stop = False
cofnig: {'job-0':{'thread_limit': 50},,,}
dataset/ETHPy150Open everydo/ztq/ztq_worker/ztq_worker/buffer_thread.py/BufferThread.__init__