#NEWLINE# def load( self ) : #NEWLINE# #INDENT# pool = Pool ( 8 ) #NEWLINE# for xmb in iter_data ( self . X , size = self . size ) : #NEWLINE# #INDENT# xmb = pool . map ( self . load_fn , xmb ) #NEWLINE# self . batches . put ( xmb ) #NEWLINE# #UNINDENT# self . batches . put ( StopIteration )