highfive/worker.py
def run_worker_pool(job_handler, host="localhost", port=48484,
                      *, max_workers=None):
    """
    Runs a pool of workers which connect to a remote HighFive master and begin
    executing calls.
    """

    if max_workers is None:
        max_workers = multiprocessing.cpu_count()

    processes = []
    for _ in range(max_workers):
        p = multiprocessing.Process(target=worker_main,
                args=(job_handler, host, port))
        p.start()
        processes.append(p)

    logger.debug("workers started")

    for p in processes:
        p.join()

    logger.debug("all workers completed")
def run_worker_pool(job_handler, host="localhost", port=48484,
                      *, max_workers=None):
    if max_workers is None:
        max_workers = multiprocessing.cpu_count()

    processes = []
    for _ in range(max_workers):
        p = multiprocessing.Process(target=worker_main,
                args=(job_handler, host, port))
        p.start()
        processes.append(p)

    logger.debug("workers started")

    for p in processes:
        p.join()

    logger.debug("all workers completed")
def run_worker_pool ( job_handler , host = "localhost" , port = 48484 , * , max_workers = None ) : if max_workers is None : max_workers = multiprocessing . cpu_count ( ) processes = [ ] for _ in range ( max_workers ) : p = multiprocessing . Process ( target = worker_main , args = ( job_handler , host , port ) ) p . start ( ) processes . append ( p ) logger . debug ( "workers started" ) for p in processes : p . join ( ) logger . debug ( "all workers completed" )
Runs a pool of workers which connect to a remote HighFive master and begin
    executing calls.
Runs a pool of workers which connect to a remote HighFive master and begin executing calls .