def run(strategyClass, address, port, workerCount=None, workerName=None):

    assert(workerCount is None or workerCount > 0)
    if workerCount is None:
        workerCount = multiprocessing.cpu_count()

    workers = []
    # Build the worker processes.
    for i in range(workerCount):
        workers.append(multiprocessing.Process(target=worker_process, args=(strategyClass, address, port, workerName)))

    # Start workers
    for process in workers:
        process.start()

    # Wait workers
    for process in workers:
        process.join()
Executes one or more worker processes that will run a strategy with the bars and parameters supplied by the server.
dataset/ETHPy150Open gbeced/pyalgotrade/pyalgotrade/optimizer/worker.py/run