(self, meta, sampler, num_processes=None, max_qsize=20)
Params:
      num_processes: number of IO processes. Default = None (# CPU cores).
      max_qsize: multiprocessing.Queue(maxsize=max_qsize).
      method: queue(use manager.Queue), async_result(AsyncResult.get())
Params:
      num_processes: number of IO processes. Default = None (# CPU cores).
      max_qsize: multiprocessing.Queue(maxsize=max_qsize).
      method: queue(use manager.Queue), async_result(AsyncResult.get())
Params : num_processes : number of IO processes . Default = None ( # CPU cores ) . max_qsize : multiprocessing . Queue ( maxsize = max_qsize ) . method : queue ( use manager . Queue ) async_result ( AsyncResult . get () )
def __init__(self, meta, sampler, num_processes=None, max_qsize=20):
    '''
    Params:
      num_processes: number of IO processes. Default = None (# CPU cores).
      max_qsize: multiprocessing.Queue(maxsize=max_qsize).
      method: queue(use manager.Queue), async_result(AsyncResult.get())
    '''
def __init__ ( self , meta , sampler , num_processes = None , max_qsize = 20 ) :