proposals.py 文件源码

def Proposal_Massive(days_list=None,
                     proposal_days_interval=1,
                     CPUs=4,
                     collection=COLLECTION):

    assert isinstance(days_list, list), "Days list must be a list"

    days_count = len(days_list)

    pool = ThreadPool(CPUs)

    try:
        print "Creating proposals for days between {}-{} in {}".format(days_list[0], days_list[-1], collection)
        pool.map(Proposal_creator, (
            (day, proposal_days_interval, idx + 1, days_count, collection)
            for idx, day in enumerate(days_list)))

    except Exception as e:
        print "Thread error at processing '{}'".format(e)

    pool.close()
    pool.join()