reader.py 文件源码

def go(self):
        dataset_dialect = csv.get_dialect('dataset_dialect')
        args = ([self.batch_gen_args,
                 SerializableDialect.from_dialect(dataset_dialect),
                 self.queue])
        self.p = multiprocessing.Process(target=self._shove,
                                         args=args,
                                         name='Shovel_Proc')
        self.p.start()
        return self.p