(self)
Start sampling async.
Start sampling async.
Start sampling async .
def start(self):
    ''' Start sampling async. '''
    self.pool = mp.Pool(self.num_processes)
    pool_args = [(self.mp_queue, x) for x in self.meta.utts.items()]
    self.pool_res = self.pool.map_async(
        self.sampler.get_bare_sampler(), pool_args, chunksize=100)
    self.pool.close()
def start ( self ) : self . pool = mp . Pool ( self . num_processes ) pool_args = [ ( self . mp_queue , x ) for x in self . meta . utts . items ( ) ] self . pool_res = self . pool . map_async ( self . sampler . get_bare_sampler ( ) , pool_args , chunksize = 100 ) self . pool . close ( )